新版的Kafka Producer是否仍然还有producer.type 属性设置?
老版的Kafka 中说producer.type 是一个重要的属性,但是新版的文档中并没有提到这一点。
新版的新版的Kafka Producer是否仍然还有producer.type 属性设置?
新版的Producer 默认是异步发送消息的(async),但是可以通过调用future.get() 变成同步发送消息。
由于send() 方法默认是异步的,该方法将返回消息发送结果为Future<RecordMedata>。如果调用future.get() 方法,将阻塞该请求,直到完成请求,并返回RecordMetadata 对象或者在发送消息时抛出异常。
采用同步模式发送消息记录时,系统的性能会下降很多,因为需要等待返回的消息写入结果。在生产环境中,一般不建议这样使用,建议采用异步模式。
// 实例化一个消息记录对象,用来保存topic,key,value等等 ProducerRecord<String, String> record = new ProducerRecord<String, String>( 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()); } } });
相关推荐
Kafka 2020-09-18
yanghuashuiyue 2020-11-14
liuxingen 2020-11-13
wangying 2020-11-13
王谦 2020-11-03
huangwei00 2020-10-14
shenzhenzsw 2020-10-09
guicaizhou 2020-09-30
jiaomrswang 2020-09-23
jyj0 2020-09-21
guicaizhou 2020-09-15
hannuotayouxi 2020-08-20
amwayy 2020-08-03
yangyutong00 2020-08-01
weikaixxxxxx 2020-08-01
PoppyEvan 2020-08-01
guicaizhou 2020-08-01
PoppyEvan 2020-07-29