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 分类:编程语言