rebalancing

1热度

2回答

合流的Kafka连接器 - 无法停止重新平衡

我使用合流的kafka连接器3.0.1版本。我创建了一个名为的新组，，其中有大约20个主题。这些主题中的大多数都很忙。但它可惜的是，当我启动连接器框架时，系统无法停止重新平衡，大约2分钟后所有主题的重新平衡。我不知道原因。 一些错误消息的是： [2017-01-03 21:43:57,718] ERROR Commit of WorkerSinkTask{id=new-connector-0} o

apache-kafka-connect confluent-kafka rebalancing 2017-01-03

---

1热度

1回答

Kafka在组中的一个用户被严格分配到特定分区的情况下重新平衡

Kafka重新平衡旨在将主题的所有分区重新分配给订阅者组活动成员，以便任何主题分区仅由一位消费者使用给定的时刻。因此，在情况下，如果消费者刚刚订阅的话题，一切都清楚了，但消费者的API还提供了一种特定的分区分配给消费者： void assign(Collection<TopicPartition> partitions) 现在让我们假设有： 用5个分区的主题：1,2,3,4,5 与3个成员一消费群

java apache-kafka message-queue kafka-consumer-api rebalancing 2017-03-16

---