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