线程阻止Akka-streams-kafka中的Kafka协调员

作者: 坚挺的阿袁
发布时间: 2024-12-11 05:25:54 (21天前)
转自：

2 条回复

0#
回复此人
晴天3 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 来自Java Kafka客户端 <a href="http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html" rel="nofollow noreferrer"> API </A> </p> <BLOCKQUOTE> <OL> <LI> 每个线程一个消费者一个简单的选择是为每个线程提供自己的消费者实例。以下是此方法的优缺点： PRO：这是最容易实现的PRO：它通常是最快的，因为没有需要跨线程协调PRO：它进行有序处理在每个分区的基础上很容易实现（每个线程只是按照收到消息的顺序处理消息）。 CON：更多消费者意味着与群集的TCP连接更多（每个线程一个）。一般来说 Kafka非常有效地处理连接，所以这通常是一个成本很低。 CON：多个消费者意味着发送更多请求服务器和稍微少一点的数据批处理可能会导致一些 I / O吞吐量下降。 CON：所有线程的总线程数进程将受分区总数的限制。 </LI> </醇> </BLOCKQUOTE> </DIV>

编辑

登录后才能参与评论