文件名称:disruptor-kafka-consumer:基于React流的卡夫卡消费者
文件大小:11KB
文件格式:ZIP
更新时间:2024-05-20 16:53:16
Java
卡夫卡消费者的破坏者 演示如何在Kafka 0.9 Consumer上使用LMAX Disruptor 好处->一旦先前的使用者完全处理完消息,便可以使用序列屏障来提交消息。想象力是极限。如果环形缓冲区可以容纳在L3缓存中,则处理速度会更快(取决于消息的有效负载) 想要拥有更多的消费者? 创建更多的KafkaDisruptor对象并运行它们。 KafkaDisruptor对象可确保只有1个Kafka Consumer实例与1个Disruptor Instance一起运行。 每个环形缓冲区1个生产者,可带来性能优势。
【文件预览】:
disruptor-kafka-consumer-0.0.1-SNAPSHOT
----pom.xml(3KB)
----LICENSE(1KB)
----src()
--------main()
----.gitignore(189B)
----README.md(580B)