RabbitMQ和kafka从几个角度简单的对比
业界对于消息的传递有多种方案和产品，本文就比较有代表性的两个MQ(rabbitMQ,kafka)进行阐述和做简单的对比，
在应用场...
kafka发送自定义消息体（对象、数组）
版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/u014104286/article/details/77102872
在前面简单搭建了Windows上的kaf...
Kafka中topic的Partition，Kafka为什么这么快,Consumer的负载均衡及consumerGroup的概念（来自学习笔记）
1.1． Kafka中topic的Partition
在Kafka文件存储中，同一个topic下有多个不同partition，每个partition为一个目录，partiton命名规则为topic名称+有序序...
Kafka 单机和分布式环境搭建与案例使用
版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/u010870518/article/details/77312569
实验环境：
1、Ubu...
kafka API详解
1. 生产者api
Producer是Kafka三大组件中的一个，用于发送消息到kafka集群中
Producer提供了丰富的配置（见后面的配置项）用于控制它的行为
在编码之前先使用命令创...
kafka操作API（获取topic列表、创建topic、修改topic、删除topic以及消费组的操作等）
实现kafka的管理端操作API步骤如下：
1.添加pom依赖：
<dependency>
<groupId>org.springframework.kafka</groupId>
...
kafka原理详解之各种offset和checkpoint
每一个分区都是一个顺序的、不可变的消息队列，并且可以持续的添加。分区中的消息都被分配了一个序列号，称之为偏移量(offset),在每个分区中此偏移量都是唯一...
kafka重复消费问题–consumer消费能力很低
问题描述
采用kafka读取消息进行处理时，consumer会重复读取afka队列中的数据，使用命令查看kafka消费数据时，发现待消费数据一直没变。
问题原因
...
logstash+kafka 文件日志收集
版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/zx84289061/article/details/61650408
logstash和kafka的安装和使用
ht...
Java Api Consumer 连接启用Kerberos认证的Kafka
java程序连接到一个需要Kerberos认证的kafka集群上，消费生产者生产的信息，kafka版本是2.10-0.10.0.1；
Java程序以maven构建，（怎么构建maven工程，可去问下度娘：“...