发送消息的是 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 发送时又没有指定分区。