
1、使用环境 kafka版本1.0.1kafka集群使用SASL_PLAINTEXT安全认证Broker属性auto.create.topics...
1、安全概览 社区从kafka 0.9.0.0开始支持安全机制功能,这些安全机制可以单独或混合使用。 1.1、客户端(producer、cons...
1、使用基础信息 Kafka版本1.0.1Zookeeper版本3.4.6Ranger版本1.1.0Kerberos版本1.10.3-30两个账...
环境说明: 1、1个zookeeper,3个kafka broker在同一主机。 1、创建一个test topic(3分区、3副本) kafka...
前提: 1、kafka版本1.0.12、在linux中使用kinit刷新kerberos认证信息 1、生产者 1.1、准备jaas.conf并添...
1、异常信息 2、排查过程 从下面这张图中可以看出某一topic某一分区的leader副本节点挂了。由于唯一活着的144节点,分区副本已不再IS...
1、消息流转过程 下图演示了一个简单的Kafka消息流转过程。Kafka Produce仅发送包含有topic为staff,partition为...
1、介绍 DelayedOperationPurgatory是kafka中一个非常重要的组件之一。它解决的问题是一个操作要么在满足一定业务条件下...
一、搭建第一个broker 搭建第一个Kafka broker的环境配置,请参阅我的第一篇文章(https://www.jianshu.com/...
文集作者