fk-apache-camel-kafka-async:Apache Camel Kafka组件-使用Kafka异步生产器

时间:2024-05-23 16:00:10
【文件属性】:

文件名称:fk-apache-camel-kafka-async:Apache Camel Kafka组件-使用Kafka异步生产器

文件大小:19KB

文件格式:ZIP

更新时间:2024-05-23 16:00:10

Java

fk-camel-kafka-async 新组件-Camel Kafka Producer,使用Kafka Asynchronous。 现有的Camel-Kafka 2.15组件使用单个低级生产者kafka.javaapi.Producer在发送每条消息之前都拥有一个全局锁。 Kafka Java API新增了0.8.2.x Async Producer,让他们通过将batchSize和延迟时间定义为可配置来调整锁定和延迟。 linger.ms = 0,意味着与收到消息缓冲区后立即刷新消息缓冲区一样好。


【文件预览】:
fk-apache-camel-kafka-async-master
----ReadMe.txt(99B)
----.gitignore(104B)
----src()
--------main()
--------test()
----pom.xml(5KB)
----README.md(488B)
----release.sh(677B)

网友评论