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

我正在读这篇： 自动提交提交偏移量最简单的方法是允许消费者为您执行。如果您配置启用。汽车commit=true，则每五秒钟消费者将提交客户端从poll（）收到的最大偏移量。五秒钟的间隔是默认值，由设置“自动”控制。犯罪间隔ms.与消费者中的其他所有内容一样，自动提交由轮询循环驱动。无论何时进行轮询，使用者都会检查是否到了提交的时间，如果是，它将提交上次轮询中返回的偏移量。 也许问题是我的英语不好，

我有一个服务，它从不同的Spring云流通道（绑定到EventHub/Kafka主题）生成和使用消息。有几种设置类似的服务。 配置如下所示 生产者/发布者代码如下所示 类似地，我还有多个其他发布者发布到不同的活动中心/主题。请注意，每个已发布的消息都有一个租户id标头。这是我的多租户应用程序特定于跟踪租户上下文的内容。还请注意，在发送消息时，我正在获取要发布到的频道。 我的消费者代码如下所示 同样

我没有使用Spring Kafka模块来生成和使用消息。相反，我在生产者和消费者实现中使用Apache客户端库。由于我没有使用Spring Kafka，因此Spring Slueth自动配置不适用于生成跟踪。我已经提到https://docs.spring.io/spring-cloud-sleuth/docs/current-SNAPSHOT/reference/html/integration

我们有一个基于spring boot的事务性Kafka制作人！使用的版本如下 spring-boot-starter-父-2.3.0。释放 spring-kafka-2.5.0。释放 我们的kafka（集群）版本是2.1. x！ 作为生产者，我们启用了幂等性，定义了事务id前缀，并在事务中执行kafka模板调用。我们还有一个将隔离级别设置为只读的使用者！ 现在我们遇到了一个行为，不知道如何推断，

我看到，尽管kafka主题有大量（数百万）消息排队，vert. x消费者只获取500条消息（默认获取量），然后将其传递给处理程序。但是在消息被处理和提交后，消费者只是停下来等待大约35秒，直到它获取另一批消息。 我希望消费者会继续获取，直到它设法赶上分区，然后暂停。我如何让它这样做？ 使用以下代码设置消费者: 为消费者提供以下配置： 我使用的是vert.x 3.9.2，Kafka是2.4.1

我正在阅读Kafka的文档，注意到下面一行： 但是，请注意，使用者组中的使用者实例不能多于分区。 嗯。如何自动缩放？ 这是Kafka的限制但是...如果我理解这是如何工作的，那么两个用户组都将从一个分区（例如msg.hi）中提取，并使用它们自己的偏移量，因此两个用户组都不知道另一个分区--这意味着消息可能会被传递两次！ 我怎样才能达到我在兔子设计中所拥有的Kafka的能力，并且仍然保持行为的“队列

当一个新的消费者/borker被添加或下降时，Kafka会触发一个再平衡操作。Kafka是在重新平衡封锁行动。Kafka的消费者是不是在一个再平衡操作正在进行的时候就被封锁了？

如有任何帮助，我们将不胜感激。

我正在从数据库中提取数据，以检查我是否有可用的系统资源来处理来自KafkaListener的进一步消息。如果我的条件没有满足，那么我希望@KafkaListener暂停，当条件满足时，我希望@KafkaListener恢复。我如何在SpringKafka实现这一点？ 另外，为特定分区暂停消费者有什么缺点吗？

我将Kafka用于一个消息传递应用程序。对于这个应用程序，有一个生产者将消息放入一个主题，消费者注册到这个主题，并消费这些消息。这些消费者是Dockerized应用程序。出于自动缩放的目的，每个使用者在创建时都注册为具有唯一ID的使用者。 Consumer2被创建为docker容器，并将自身注册为ID为的使用者 现在，无论出于什么原因，失败，并被替换，后者将自己注册为kafka的使用者，其ID为。

服务B可以从Eureka服务器通过服务发现获得服务A的url和portno。服务B注册尤里卡服务器有什么意义？

我试着把这个理论与缩放工人做比较。 但是，使用版本1.2.1时，storm Kafka spout在多个不同的拓扑中的行为并不像我预期的那样。 为单个主题的所有拓扑中的kafka spout使用者设置一个公共client.id和group.id，每个拓扑仍然订阅所有可用的分区和重复的元组，并在重新提交已提交的元组时抛出错误。 如果有人能解释一下 Kafka喷口的这种行为的实现逻辑是什么？ 有解决此

如有任何帮助，不胜感激。

null null 我们正在为我们的kafka broker（kafka Version2.1.1)使用Red Hat AMQ Streams 我们在环境中唯一更改的是Spring Boot版本（以及自动拉入/更新的依赖项），以重新创建此问题 以下是更改前的： 现在，如果我们只是用如下所示的新的Spring Boot版本更新，我们的kafka度量标准就会消失： 提前感谢您的帮助！如果你需要任何其他

kafka机器作为hortonworks包的一部分安装，版本为0.1X 我们运行应用程序，使用主题中的数据 在最后几天，我们看到我们的应用程序--失败了，我们开始寻找根本原因 在集群中，我们看到以下行为 从侧集群是健康的，所有的主题都是平衡的，所有的kafka经纪人都正确地向zooManager签名 一段时间后（几个小时），我们再次运行以下内容，但没有错误- 我们得到以下正确的结果 所以我们想了解