kafka
-
SpringBoot集成Kafka的步骤
SpringBoot集成Kafka 本篇主要讲解SpringBoot 如何集成Kafka ，并且简单的 编写了一个Demo 来测试 发送和消费功能[详细]
2021-01-12 11:31 分类：编程语言 处理jmx监控kafka报主机不可达问题
通过zabbix监控kafka，在给kafka配置好jmx端口后，发现通过cmdline-jmxclient进行测试时报主机不可达，检查了中间网络是放通的、被监控端selinux为permissive。[详细]
2021-01-06 19:47 分类：LinuxSpringboot 1.5.7整合Kafka-client代码示例
在一次项目中，因甲方需要使用kafka消息队列推送数据，所以需要接入kafka，并且kafka的版本是2.11。但是我们项目使用的是Springboot 1.5.7的版本，对应的springboot.kafka.starter有冲突，所以就接入了kafka-client。[详细]
2020-12-28 06:04 分类：编程语言-
Kafka producer端开发代码实例
一、producer工作流程 producer使用用户启动producer的线程，将待发送的消息封装到一个ProducerRecord类实例，然后将其序列化之后发送给partitioner，再由后者确定目标分区后一同发送到位于producer程序中的一块[详细]
2020-12-27 16:40 分类：编程语言 -
Kafka多节点分布式集群搭建实现过程详解
上一篇分享了单节点伪分布式集群搭建方法，本篇来分享一下多节点分布式集群搭建方法。多节点分布式集群结构如下图所示：[详细]
2020-12-27 16:39 分类：编程语言 -
Kafka单节点伪分布式集群搭建实现过程详解
Kafka集群搭建分为单节点的伪分布式集群和多节点的分布式集群两种，首先来看一下单节点伪分布式集群安装。单节点伪分布式集群是指集群由一台ZooKeeper服务器和一台Kafka broker服务器组成，如下图所示：[详细]
2020-12-27 16:38 分类：编程语言 Spring boot 整合KAFKA消息队列的示例
这里使用 spring-kafka 依赖和 KafkaTemplate 对象来操作 Kafka 服务。 一、添加依赖和添加配置项[详细]
2020-12-25 20:42 分类：编程语言Java kafka如何实现自定义分区类和拦截器
生产者发送到对应的分区有以下几种方式： （1）指定了patition，则直接使用；(可以查阅对应的java api, 有多种参数)[详细]
2020-12-23 20:17 分类：编程语言Kafka Java Producer代码实例详解
根据业务需要可以使用Kafka提供的Java Producer API进行产生数据，并将产生的数据发送到Kafka对应Topic的对应分区中，入口类为：Producer[详细]
2020-12-23 19:42 分类：编程语言-
Spring boot集成Kafka消息中间件代码实例
一．创建Spring boot项目，添加如下依赖 <dependency> <groupId>org.springframework.boot</groupId>[详细]
2020-12-23 16:00 分类：编程语言
加载中,请稍侯......