0
A
回答
0
从Java客户端卡夫卡API
- 一个消费者,每线程A简单的选择是为每个线程提供自己的消费情况。这种方法的优点和缺点如下: PRO:这是最容易实现的PRO:它通常是最快的,因为不需要 线程间协调PRO:它按顺序处理 ,分区的基础很容易实现(每个线程只需 按照接收它们的顺序处理消息)。 CON:更多消费者 意味着到群集的更多TCP连接(每个线程一个)。总的来说, 卡夫卡处理连接非常有效,所以这通常是一个小的成本 。 CON:多个消费者意味着更多的请求被发送到服务器并且稍微减少数据的批量,这可能导致I/O吞吐量的一些下降。 CON:所有 进程中的总线程数将受限于分区总数。
相关问题
- 1. Akka Kafka自定义串行器
- 2. Kafka日志处理流程
- 3. OpenMP阻塞线程中的调用
- 4. 在.Net中阻塞线程
- 5. 无法在春季云流kafka中设置kafka属性
- 6. 春天云流kafka
- 7. 将线程阻塞转换为f中的非线程阻塞#
- 8. Java输入流“阻塞”和多线程
- 9. 关闭流阻塞线程吗?
- 10. 线程中断未终止输入流读取阻塞调用
- 11. Delegate.BeginInvoke回调阻塞调用线程?
- 12. 并行使用Akka Streams Kafka Producer
- 13. 从JSON到Avro的Kafka流
- 14. 阻塞队列不阻塞线程?
- 15. 阻塞线程的调用方法
- 16. 阻止Tomcat中的线程阻塞
- 17. Kafka与Kafka Direct的区别?
- 18. 阻塞线程 - Java
- 19. Java线程阻塞
- 20. Java线程阻塞
- 21. MessageBeep线程阻塞
- 22. Kafka 10 kafka-consumer-groups.sh与Kafka 8 kafka-run-class.sh ConsumerOffsetChecker
- 23. 在Django中阻塞网络调用阻止所有线程?
- 24. 中止阻塞线程
- 25. Kafka的Spark流:如何从Kafka consumer DStream获取主题名称?
- 26. 多线程的Kafka Consumer或PerPartition-PerConsumer
- 27. Spark + Kafka streaming NoClassDefFoundError kafka/serializer/StringDecoder
- 28. Kotlin:使用非阻塞I/O阻塞协程
- 29. python中的非阻塞子流程
- 30. 在C中阻塞线程组#