Mat*_*son 1 multithreading apache-kafka kafka-consumer-api
可以将给定分区中的消息划分为多个线程吗?假设我有一个分区,每个进程有一百个进程,每个进程有一百个线程-我的单个分区中的消息是否仅提供给这10000个线程中的一个?
多个线程不能使用同一分区,除非这些线程位于不同的使用者组中。尽管您有许多空闲的使用者,但是只有一个线程会使用来自单个分区的消息。
分区的数量是Kafka中并行性的单位。为了使多个使用者使用同一个分区,必须将主题的分区数增加到要实现的并行度,或者将每个线程放入单独的使用者组,但是我认为后者是不可取的。