在主题上调用 Subscribe(topicname) 和调用 Assign(TopicPartition) 有什么区别?
两者都尝试后,我发现我仍然可以调用 Consume() 并且消费者会收到可用的消息。
我注意到的一个区别是,在订阅时,消费者在超过最大轮询间隔后得到(EAGER)重新平衡。使用 Assign(TopicPartition) 时不会发生这种情况。如果有人也可以详细说明这一点。
在主题上调用 Subscribe(topicname) 和调用 Assign(TopicPartition) 有什么区别?
两者都尝试后,我发现我仍然可以调用 Consume() 并且消费者会收到可用的消息。
我注意到的一个区别是,在订阅时,消费者在超过最大轮询间隔后得到(EAGER)重新平衡。使用 Assign(TopicPartition) 时不会发生这种情况。如果有人也可以详细说明这一点。