《中邮消费金融有限公司》专题

所以，我一直在复习我对传统Java非阻塞应用编程接口的理解。我对应用编程接口的几个方面有点困惑，这些方面似乎迫使我手动处理背压。 例如，WritableByteChannel.write（ByteBuffer）上的留档说明如下： 除非另有说明，写入操作只有在写入所有请求的字节后才会返回。某些类型的通道，根据其状态，可能只写入部分字节，也可能根本不写入。例如，处于非阻塞模式的套接字通道不能写入超过套

我希望你一切都好。我挣扎了几天，因为Laravel护照，试图用javascript/vuejs消耗我自己的api。最后一个晚上，我几乎阅读了所有关于我问题的帖子，但我找不到任何解决办法。我希望你能帮助我，在这一点上谢谢你。 我已经建立了一个新的laravel应用程序，并安装了Laravel Passport，就像在Laravel 5.8（https://laravel.com/docs/5.8/p

我知道，如果我们在消费者组中有多个分区和几乎相同数量的消费者，那么处理速度会加快。如果我们想保持事件的顺序并在收到每个事件时处理它，我们如何使用多个分区和消费者来实现这一点。 在我的用例中，按顺序处理事件非常关键，否则系统会崩溃。我想使用多个分区来增加并行性，但不知何故“让它们按顺序”。

我正在尝试使用PollRich获得JPA实体 但是在那之后，尽管表包含数百行，但我只得到一行。如何获取所有行？我想要像往常一样的polEnrich行为，它给我所有的表行。

我在这里查看了Confluent Kafka库中的消费者实现，感觉它们在功能上是相同的，只是在返回的内容方面有所不同。 Poll（）调用consumer（）来查看是否有消息准备好要拾取，如果是，则调用OnMessage事件。versour,consumer,将消息保存在它的一个参数中,并返回一个布尔值。我觉得不同之处在于实现上，功能上是相同的https://github.com/confluent

用例如下。我在Java代码中的许多对象实例上传递生产者或消费者引用。在其中一些地方，我想对Kafka的配置进行一些检查。这意味着我想回去，Kafka生产者/消费者（包括默认值）中存储了什么样的有效配置。我在java文档中没有看到显式的anthing： Kafka制作人 那么，如何找回Kafka制作人和消费者的配置呢？

谁能建议在spring启动其kafka消费者之前如何运行初始化我的应用程序的方法？我正在使用spring的@KafkaListener注释创建一个kafka消费者

我对Kafka很陌生。我有一个要求，在那里我只需要阅读一些特定的消息。

有没有其他方法可以做到这一点？

我有五个Kafka消费服务和一个Kafka生产服务。我在每个Java消费微服务的消费者库中推出了一个新的avro模式。我还没有做出制片人方面的改变。但其中一个消费服务无法序列化任何内容，其他四个工作正常。 我有个例外 在生产者和消费者方面发生变化的一些事情是kafka-avro-序列化器的版本到6.0.0 kafka-客户端到2.0.0 因此，到达该消费者的记录为空，并且在我们的配置中阻塞了我们的

我已经编写了一个streams应用程序，用于在由5个代理和10个分区组成的集群上与主题对话。我在这里尝试了多种组合，比如10个应用程序实例（在10台不同的机器上），每个实例有1个流线程，5个实例每个实例有2个线程。但由于某种原因，当我签入kafka manager时，分区和流线程之间的1:1映射没有发生。一些线程正在拾取2个分区，而一些线程没有拾取任何分区。你能帮我做同样的事吗？？所有线程都是同一

我试图写一个Kafka消费者从一开始就消费这些信息。我可以从控制台消费者开始使用同样的方法 但是我在JAVA API中找不到相应的属性。 还有一个问题是什么应该是价值。Avro消息的反序列化程序？

假设： Kakfa消费者从其分配的分区P读取消息M 它将网络与代理隔离 Kafka检测到这一点，并将P重新分配给另一台机器上的消费者 网络分区已修复，第一个使用者尝试提交消息M的偏移量 在步骤4中会引发任何异常吗？是否有检查可以检测到第一个消费者不再被分配分区P，因此不应该为其提交偏移量？

顾名思义，有没有一种方法可以在java中获取特定主题的消费者列表？直到现在我才能得到这样的主题列表 但我还没有找到一种方法来获得每个主题的消费者名单