关于Kafka java consumer管理TCP连接的讨论
本篇是《关于Kafka producer管理TCP连接的讨论》的续篇，主要讨论Kafka java consumer是如何管理TCP连接。实际上，这两篇大部分的内容是相同的，即consumer也是把TCP连接的管理交由底层的Selector类 ...
原文：关于Kafka producer管理TCP连接的讨论
在Kafka中，TCP连接的管理交由底层的Selector类 org.apache.kafka.common.network 来维护。Selector类定义了很多数据结构，其中最核心的当属java.nio.channels.Selector实例，故所有的IO事件实际上是使用Java的Selector来完成的。本文我们探讨一下producer与Kafka集群进行交互时TCP连接的管理与维护。 一 ...
2018-12-13 10:58 5 4893 推荐指数：
相关推荐
关于Kafka幂等producer的讨论
众所周知，Kafka 0.11.0.0版本正式支持精确一次处理语义(exactly once semantics，下称EOS)。Kafka的EOS主要体现在3个方面： 幂等producer：保证发送单个分区的消息只会发送一次，不会出现重复消息 事务(transaction)：保证 ...
Kafka实践1--Producer
一、Kafka设计原理参考： http://blog.csdn.net/suifeng3051/article/details/48053965?locationNum=2 http://www.cnblogs.com/metoy/p/4452124.html 二、常见问题 ...
Kafka学习-Producer和Customer
在上一篇kafka入门的基础之上，本篇主要介绍Kafka的生产者和消费者。 Kafka 生产者 kafka Producer发布消息记录到Kakfa集群。生产者是线程安全的，可以在多个线程之间共享生产者实例。一个简单的例子，使用producer发送一个有序的key/value(键值 ...
alpakka-kafka(1)-producer
alpakka项目是一个基于akka-streams流处理编程工具的scala/java开源项目，通过提供connector连接各种数据源并在akka-streams里进行数据处理。alpakka-kafka就是alpakka项目里的kafka-connector。对于我们来说：可以用 ...
kafka producer源码
producer接口： View Code producer接口由两个实现类KafkaProducer、MockProducer KafkaProducer类： View Code MockProducer类 ...
Kafka Producer接口
参考， https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example http://kafka.apache.org/08/configuration.html , 0.8版本，关于producer ...
详解Kafka Producer
上一篇文章我们主要介绍了什么是 Kafka，Kafka 的基本概念是什么，Kafka 单机和集群版的搭建，以及对基本的配置文件进行了大致的介绍，还对 Kafka 的几个主要角色进行了描述，我们知道，不管是把 Kafka 用作消息队列、消息总线还是数据存储平台来使用，最终是绕不过消息这个词的，这也 ...