启用spring-kafka 在spring boot 配置类上添加 配置kafka 在application.properties中添加配置 生产者 消费者者 项目中使用 ...

一、Kafka 核心 API 　　上文中对 Kafka 做了一些简单的介绍，那么在开发过程中我们如何去访问 Kafka 呢？这就需要使用到本文将要介绍的Kafka客户端API。下图是官方文档中的一个图，形象的描述了能与 Kafka集成的客户端类型 Kafka的五类客户端API类型 ...

启动kafka正常 1.创建一个spring boot项目 2.配置使用kafka 引入依赖（gradle） implementation 'org.springframework.kafka:spring-kafka' 添加配置文件（全部使用java配置 ...

前言 一般情况下，我们都习惯使用kafka-topics.sh脚本来管理主题，但有些时候我们希望将主题管理类的功能集成到公司内部的系统中，打造集管理、监控、运维、告警为一体的生态平台，那么就需要以程序调用API的方式去实现。 Kafka社区于0.11版本正式推出了Java客户端版 ...

AdminClient 类提供了创建、删除 topic 的 api。 在项目中创建了一个 AdminClient 对象，每次创建 topic 时，调用 如果长时间不使用这个对象，客户端与 broker 之间的连接会被关掉，相关的参数： 这个最大空闲参数 ...

1、创建集群 http://kafka.apache.org/documentation/#quickstart 有一句我觉得特别重要： For Kafka, a single broker is just a cluster of size one. 1.1、命令行操作 ...

一.软件版本 　　1.linux：centos6 　　2.zookeeper：zookeeper-3.4.1 　　3.kafka：kafka_2.12-2.2.0 　　4.jdk：1.8　　5.instelliJ Idea 二.环境准备 　　1.关闭防火墙：service ...

　　1.项目搭建 　　2.关键代码与配置 　　3.性能调优 注意,本项目基于spring boot 1,如果是spring boot 2有可能会报错.相应的包需要更新 1.项目搭建 　　kafka版本:kafka_2.11-1.0.0 　　jar包版本 ...