#
排查logstash3.4升级到5.0版本后kafka不兼容问题参考文档：/usr/share/logstash/vendor/bundle/jruby/1.9/gems/logstash-input
1. 消费语义的介绍 at last once：至少消费一次（对一条消息有可能多次消费，有可能会造成重复消费数据） 原因：Proudce
hu本期内容： 1、Kafka解密背景： 目前No Receivers在企业中使用的越来越多，No Receivers具有更强的控制度，语义一致性。No Recei
一、简介1、消息传输流程Kafka is a distributed,partitioned,replicated commit logservice。它提供了类似于JMS的特性，但是在设计实现上完全
问题描述： 线上出现一台服务器特别慢，于是关闭了服务器上的kafka broker. 关闭后发现一些kafka consumer无法正常消费数据了, 日志错误：o.a.kakfa.clients.co
这篇文章主要讲解了Kafka Java Producer代码实例的详细解析，内容清晰明了，对此有兴趣的小伙伴可以学习一下，相信大家阅读完之后会有帮助。根据业务需要可以使用Kafka提供的Java Pr
这篇文章主要讲解了Python如何通过kerberos安全认证操作kafka，内容清晰明了，对此有兴趣的小伙伴可以学习一下，相信大家阅读完之后会有帮助。如何通过Kerberos认证.1.安装Kerbe
1.zookeeper集群部署不在简介zk对外提供2181端口 分别部署在三台机器上面，也是下面的三台2.hosts文件一定要做 否则kafka系统启动不起来[root@linux-node1&nbs
一、搭建Zookeeper集群Zookeeper是一个分布式开源框架，提供了协调分布式应用的基本服务，它向外部应用暴露一组通用服务——分布式同步（Distributed Synchronization
这篇文章主要讲解了Java中kafka自定义分区类和拦截器的实现方法，内容清晰明了，对此有兴趣的小伙伴可以学习一下，相信大家阅读完之后会有帮助。生产者发送到对应的分区有以下几种方式：（1）指定了pat
