我在 php 中有一個生產(chǎn)者發(fā)布到隊列。我正在使用php-rdkafka庫。以下是代碼： $conf->set('log_level', LOG_DEBUG); $conf->set('debug', 'all'); $rk = new RdKafka\Producer($conf); $rk->addBrokers("34.93.118.165:9092"); $topic = $rk->newTopic("download_first"); $topic->produce(RD_KAFKA_PARTITION_UA, 0, utf8_encode($message)); $rk->flush(100);我有 2 個 python 消費者從隊列中消費。該主題有 10 個分區(qū)。大多數(shù)情況下，當(dāng)一條新消息產(chǎn)生時，它會進(jìn)入與以前相同的分區(qū)，該分區(qū)由單個消費者使用，結(jié)果其他消費者閑置。在生成消息時是否有任何其他分區(qū)程序分配我可以使用的東西？
1 回答
三國紛爭
TA貢獻(xiàn)1804條經(jīng)驗 獲得超7個贊
根據(jù)文檔RD_KAFKA_PARTITION_UA 用于使用automatic partitioning using the topic's partitioner function，或者您可以傳遞確切的分區(qū)號而不是 RD_KAFKA_PARTITION_UA 來強制分區(qū)。
或者您要求$conf->setPartitioner(RD_KAFKA_MSG_PARTITIONER_RANDOM);啟用隨機分區(qū)程序功能。這是可能的常量列表setPartitioner
- 1 回答
- 0 關(guān)注
- 344 瀏覽
添加回答
舉報
0/150
提交
取消