トピックで Subscribe(topicname) を呼び出すことと Assign(TopicPartition) を呼び出すことの違いは何ですか?
両方を試した後、まだ Consume() を呼び出すことができ、コンシューマーは利用可能なメッセージを受け取ることがわかりました。
私が気付いた違いの 1 つは、サブスクライブすると、最大ポーリング間隔を超えた後に Consumer が (EAGER) Rebalanced を取得することです。これは、Assign(TopicPartition) が使用されている場合には発生しません。誰かがこれについても詳しく説明できる場合。