問題タブ [confluent-kafka-python]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票する
0 に答える
5 参照

confluent-kafka-python - 異なるパーティションへの異なる Equipment_id

私はequipment_idそれが可能で1, 5, 7 or 10あり、それらを異なるパーティションに配置したいと考えています。どうやってやるの?最初に適切な数のパーティション (この場合は 4) を作成する必要がありますか? もしそうなら、次は何ですか?

メソッドにはpartitionパラメータがありますproduce()。ただし、パーティションのシリアル番号は受け入れます: 0, 1, 2, 3. パラメータを定義するstr(equipment_id)key、常にパーティション 0 にデータが送信されます (の出力によるとdelivery_callback())。