
生产端:
使用同步的发送,ack设置成非0的值。
消费者端:
主题只能设置一个分区,消费组中只能有一个消费者。
注意:
Kafka对于顺序消费这一块并不如RocketMQ做的好。
如果强行让kafka做到消息的顺序消费也不是不行,只是会让kakfa的性能变的很差!
拓展:RocketMQ:
阿里内部的一个大神利用自己的业余时间根据kafka的底层原理自己纯手写出的一套消息中间件。
虽然性能比不上kafka,但是在一些解决方案上要比Kafka优秀。例如RocketMQ内部对消息的顺序消费已经做好了封装,而kafka并非如此。