云中的卡夫卡消费者

Question

我使用的春季卡夫卡消费者包裹在春季启动应用程序中，并在关键云代工厂部署为微服务。我正在部署15个应用程序的实例，其中包括15个kafka分区。由于这些实例中的大多数会逐个启动，会有多次重新平衡吗？在云中部署kafka用户的推荐方式是什么？

Answer 1

新的0.11客户端有一个新的属性group.initial.rebalance.delay.mssee Notable changes in 0.11.0.0。

引入了一个新配置group.initial.rebalance.delay.ms。此配置指定以毫秒为单位的时间，即GroupCoordinator将延迟初始消费者重新平衡。当新成员加入该组时，重新平衡将进一步延迟group.initial.rebalance.delay.ms的值，最多可达max.poll.interval.ms。这个的默认值是3秒。在开发和测试期间，可能希望将其设置为0，以便不延迟测试执行时间。

我们正在为0.11客户端添加支持。目前计划用于Apache Kafka发布的2.0 Spring，但我们正在考虑1.3版本的2.0功能的子集，并支持0.11。

你可以尝试使用新的客户端与较旧的春季卡夫卡;它可能工作，但当然，你不会得到0.11的功能，如交易和Headers。