我使用的是SpringKafka消费者，它们被 Package 在SpringBoot应用程序中，并作为微服务部署在pivotal cloud foundry中。我正在部署15个应用程序示例和15个kafka分区。由于这些示例中的大多数都是一个接一个地启动的，是否会执行多次重新平衡？在云中部署kafka消费者的推荐方法是什么？
k5ifujac1#
新的0.11客户端有一个新属性 group.initial.rebalance.delay.ms 请参见0.11.0.0中的显著更改。一个新的配置， group.initial.rebalance.delay.ms 介绍了。此配置以毫秒为单位指定 GroupCoordinator 将推迟最初的消费者再平衡。再平衡将因 group.initial.rebalance.delay.ms 当新成员加入组时，最多 max.poll.interval.ms . 默认值为3秒。在开发和测试期间，为了不延迟测试执行时间，最好将其设置为0。我们正在为0.11客户端添加支持。目前计划在ApacheKafka的2.0Spring版本中发布，但我们正在考虑1.3版本，其中包含2.0特性的一个子集，以及对0.11的支持。您可以尝试将新客户机与旧的spring kafka一起使用；它可能会工作，但是，当然，您不会得到0.11特性，例如事务和 Headers .
group.initial.rebalance.delay.ms
GroupCoordinator
max.poll.interval.ms
Headers
1条答案
按热度按时间k5ifujac1#
新的0.11客户端有一个新属性
group.initial.rebalance.delay.ms请参见0.11.0.0中的显著更改。一个新的配置，
group.initial.rebalance.delay.ms介绍了。此配置以毫秒为单位指定GroupCoordinator将推迟最初的消费者再平衡。再平衡将因group.initial.rebalance.delay.ms当新成员加入组时，最多max.poll.interval.ms. 默认值为3秒。在开发和测试期间，为了不延迟测试执行时间，最好将其设置为0。我们正在为0.11客户端添加支持。目前计划在ApacheKafka的2.0Spring版本中发布，但我们正在考虑1.3版本，其中包含2.0特性的一个子集，以及对0.11的支持。
您可以尝试将新客户机与旧的spring kafka一起使用；它可能会工作，但是，当然，您不会得到0.11特性，例如事务和
Headers.