自動コミットが可能な状態で、手動でパーティションを割り当てる方法を教えてください。

Question

私は、コンシューマ・グループ内の各コンシューマにパーティションを手動で割り当てようとしています。ただし、グループにコンシューマを追加すると、Kafka（または少なくともkafka-python）は、グループコーディネータにすべての割り当てを行うことを前提としています。コンシューマ・グループ（特に自動コミット）を使用することの利点をすべて維持しながら、パーティションの割り当てを手動で管理できる方法はありますか？カスタムパーティション割り当てを書くことはできますか？

私はkafka-python 1.3.3ライブラリを使用しています。

Answer 1

カフカの消費者は、独自のカスタム譲渡を指定することができますプロパティ「partition.assignment.strategy」を、持っているはい、デフォルトはRangeAssignor

自動コミットでは、プロパティは「enable.auto.commit」

を駆動され、

カフカ消費者設定： https://kafka.apache.org/documentation/#consumerconfigs