Spring KafkaTemplate,它是一个单线程的,速度很慢。
消息接收速度、消息处理速度:
如果一个消息的接收速度很快,
但是这个消息的处理速度很慢,
那么整体还是很慢。
(早知如此,当初为什么还要用Kafka?用个activemq/rabbitmq效果不是一样的么?
接收快,接收之后处理慢,还不如接收也慢一点)
Kafka一个分区对应一个线程
如果topic是20个分区 消费者是16个线程 那么会有4个分区的消息不会被消费
Kafka的消息是无序的;如果要有序,只能有一个分区。
如果一个topic有10个分区,
那么“多线程处理一个topic的消息”和“多线程处理某个分区的消息”是一个意思吗?
后者是不是要在线程里面再起线程?
--
修改:PlutoKey FROM 117.155.136.*
FROM 117.155.136.*