|
|
老版的Kafka 中说producer.type 是一个重要的属性，可是新版的文档中并没有提到这一点。
新版的新版的Kafka Producer能否仍然还有producer.type 属性设备？
新版的Producer 默许是异步发送消息的（async），可是可以经过挪用future.get() 酿成同步发送消息。
由于send() 方式默许是异步的，该方式将返回消息发送成果为Future。假如挪用future.get() 方式，将阻塞该请求，直到完成请求，并返回RecordMetadata 工具大概在发送消息时抛出异常。
采用同步形式发送消息记录时，系统的性能会下降很多，由于需要期待返回的消息写入成果。在生产情况中，一般不倡议这样利用，倡议采用异步形式。
// 实例化一个消息记录工具，用来保存topic,key,value等等
ProducerRecord record = new ProducerRecord(
topic, key, value);
// 挪用send() 方式和回调函数
kafkaProducer.send(record, new Callback() {
@Override
public void onCompletion(RecordMetadata recordMetadata, Exception e) {
if (e != null) {
e.printStackTrace();
} else {
System.out.println("offset: " + recordMetadata.offset());
}
}
}); |
本帖子中包含更多资源
您需要 登录 才可以下载或查看，没有帐号？立即注册
x
|
[复制链接]
发表于 2020-10-9 18:24:05
发表于 2020-10-9 18:55:29
