PHP librdkafka 如何消费消息

[110male]

发送消息的是 java public void sendMsg(String topic, String key, String value) { // 实例化 produce KafkaProducer<String, String> kp = new KafkaProducer<String, String>(properties); // 消息封装 ProducerRecord<String, String> pr = new ProducerRecord<String, String>(topic,key,value);

    // 发送数据
    kp.send(pr, new Callback() {
        // 回调函数
        @Override
        public void onCompletion(RecordMetadata metadata, Exception exception) {
            if (null != exception) {
                System.out.println(exception.getMessage() + exception);
            }
        }
    });
    // 关闭 produce
    kp.close();
}





消费消息的是 php,参考的是文档的示例： https://arnaud-lb.github.io/php-rdkafka/phpdoc/rdkafka.examples-low-level-consumer-basic.html
// Start consuming partition 0

$topic->consumeStart(0, RD_KAFKA_OFFSET_STORED);

0 代表的是分区，但是我怎么知道，是发送到哪儿个分区了呢？ java 发送时又没有指定分区。