我想知道Kafka消费者（java客户机）是否可以并行地读取和处理多条消息。。。我应该用rxjava吗？？1） 这是一个好办法吗？？？2） 根据我的理解，Kafka甚至把每一条线都当作一个消费者…如果我错了，请纠正我。。。3） 还想让java客户机作为守护进程服务在linux中运行，这样它就可以连续运行并轮询kafka的消息，读取和处理相同的消息..这是一个好方法。。
wj8zmpe11#
kafka支持按分区并行处理消息，您可以启动多个使用者，一个kafka客户端可以启动一个或多个分区，kafka也可以通过这种方式支持同一分区的顺序处理。当然，您可以在一个使用者中启动多个线程来处理多个消息，但是不能保证在一个分区中进行顺序处理。
1条答案
按热度按时间wj8zmpe11#
kafka支持按分区并行处理消息，您可以启动多个使用者，一个kafka客户端可以启动一个或多个分区，kafka也可以通过这种方式支持同一分区的顺序处理。
当然，您可以在一个使用者中启动多个线程来处理多个消息，但是不能保证在一个分区中进行顺序处理。