disruptor-kafka-consumer:基于React流的卡夫卡消费者

卡夫卡消费者的破坏者 演示如何在Kafka 0.9 Consumer上使用LMAX Disruptor 好处->一旦先前的使用者完全处理完消息，便可以使用序列屏障来提交消息。想象力是极限。如果环形缓冲区可以容纳在L3缓存中，则处理速度会更快（取决于消息的有效负载） 想要拥有更多的消费者？ 创建更多的KafkaDisruptor对象并运行它们。 KafkaDisruptor对象可确保只有1个Kafka Consumer实例与1个Disruptor Instance一起运行。 每个环形缓冲区1个生产者，可带来性能优势。