您好,欢迎来到年旅网。
搜索
您的当前位置:首页Spring Kafka KafkaTemplate 如何使用异步、同步发送消息以及区别区别

Spring Kafka KafkaTemplate 如何使用异步、同步发送消息以及区别区别

来源:年旅网

KafkaTemplate默认是异步发送

异步发送:

代码使用:

kafkaTemplate.send(topic,message);

其中topic,message是范指。

原理:

异步发送消息时,只要消息积累达到batch.size值或者积累消息的时间超过linger.ms(二者满足其一),producer就会把该批量的消息发送到topic中。
注:batch.size默认是16384,linger.ms默认是0

同步发送:

代码使用:

kafkaTemplate.send(topic,message

因篇幅问题不能全部显示,请点此查看更多更全内容

Copyright © 2019- oldu.cn 版权所有 浙ICP备2024123271号-1

违法及侵权请联系:TEL:199 1889 7713 E-MAIL:2724546146@qq.com

本站由北京市万商天勤律师事务所王兴未律师提供法律服务