花费 18 ms
关于Kafka producer管理TCP连接的讨论

  在Kafka中,TCP连接的管理交由底层的Selector类(org.apache.kafka.common.network)来维护。Selector类定义了很多数据结构,其中最核心的当属java ...

Thu Dec 13 18:58:00 CST 2018 5 4893
关于Kafka幂等producer的讨论

  众所周知,Kafka 0.11.0.0版本正式支持精确一次处理语义(exactly once semantics,下称EOS)。Kafka的EOS主要体现在3个方面: 幂等producer ...

Tue Oct 24 06:20:00 CST 2017 2 5655
Kafka producer拦截器(interceptor)

  Producer拦截器(interceptor)是个相当新的功能,它和consumer端interceptor是在Kafka 0.10版本被引入的,主要用于实现clients端的定制化控制逻辑。 ...

Sat Jun 24 16:37:00 CST 2017 0 5797
Kafka producer介绍

Kafka 0.9版本正式使用Java版本的producer替换了原Scala版本的producer。本文着重讨论新版本producer的设计原理以及基本的使用方法。 新版本Producer 首先 ...

Sun Feb 05 01:21:00 CST 2017 2 5261
【译】Kafka Producer Sticky Partitioner

最近事情多有点犯懒,依然带来一篇译文:Apache Kafka Producer Improvements with the Sticky Partitioner 消息在系统中流转的时间对于Ka ...

Sun Mar 22 01:54:00 CST 2020 0 1318
kafka-producer kerberos 原理和配置

kerberos简单介绍 kerberos这一名词来源于希腊神话“三个头的狗---地狱之门守护者”后来沿用作为安全认证的概念,该系统设计上 采用客户端/服务器结构与DES(Data Encrypt ...

Wed Jun 06 21:52:00 CST 2018 0 973

 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM