文章列表
-
- Zabbix对Kafka topic积压数据监控的解决方案
- 这篇文章主要介绍了Zabbix对Kafka topic积压数据监控的解决方案,它与Apache Storm和Spark非常好地集成，用于实时流式数据分析，需要的朋友跟随小编一起看看吧
- 日期：2023-04-06
- 浏览：618
- 标签： Zabbix
-
- Java Kafka 消费积压监控的示例代码
- 后端代码：Monitor.java代码：package com.suncreate.kafkaConsumerMonitor.service;import com.suncreate.kafkaConsumerMonitor.model.ConsumerInfo;import org.apache....
- 日期：2022-08-10
- 浏览：68
- 标签： Java
-
- spring 整合kafka监听消费的配置过程
- 前言最近项目里有个需求，要消费kafka里的数据。之前也手动写过代码去消费kafka数据。但是转念一想。既然spring提供了消费kafka的方法。就没必要再去重复造轮子。于是尝试使用spring的API。项目技术背景，使用springMVC，XML配置和注解相互使用。kafka的配置都是使用XML...
- 日期：2023-07-20
- 浏览：156
- 标签： Spring
-
- Spring Boot 集成 Kafkad的实现示例
- Spring Boot 作为主流微服务框架，拥有成熟的社区生态。市场应用广泛，为了方便大家，整理了一个基于spring boot的常用中间件快速集成入门系列手册，涉及RPC、缓存、消息队列、分库分表、注册中心、分布式配置等常用开源组件，大概有几十篇文章，陆续会开放出来，感兴趣同学请提前关注&...
- 日期：2023-07-18
- 浏览：60
- 标签： Spring
-
- Springboot 1.5.7整合Kafka-client代码示例
- 在一次项目中，因甲方需要使用kafka消息队列推送数据，所以需要接入kafka，并且kafka的版本是2.11。但是我们项目使用的是Springboot 1.5.7的版本，对应的springboot.kafka.starter有冲突，所以就接入了kafka-client。Kafka 是一个分布式消息...
- 日期：2023-04-13
- 浏览：69
- 标签： Spring
-
- Java kafka如何实现自定义分区类和拦截器
- 生产者发送到对应的分区有以下几种方式：（1）指定了patition，则直接使用；(可以查阅对应的java api, 有多种参数)（2）未指定patition但指定key，通过对key的value进行hash出一个patition；（3）patition和key都未指定，使用轮询选出一个patitio...
- 日期：2022-08-31
- 浏览：107
- 标签： Java
-
- Java将CSV的数据发送到kafka的示例
- 为什么将CSV的数据发到kafka flink做流式计算时，选用kafka消息作为数据源是常用手段，因此在学习和开发flink过程中，也会将数据集文件中的记录发送到kafka，来模拟不间断数据； 整个流程如下： 您可能会觉得这样做多此一举：flink直接读取CSV不就行了吗？这样做的原因如...
- 日期：2022-08-21
- 浏览：46
- 标签： Java
-
- java自己手动控制kafka的offset操作
- 之前使用kafka的KafkaStream，让每个消费者和对应的patition建立对应的流来读取kafka上面的数据，如果comsumer得到数据，那么kafka就会自动去维护该comsumer的offset，例如在获取到kafka的消息后正准备入库（未入库），但是消费者挂了，那么如果让kafka...
- 日期：2022-08-16
- 浏览：291
- 标签： Java
-
- 利用扩展的方式在PHP中使用Kafka的教程分享
- 这篇文章主要为大家详细介绍了如何利用扩展的方式实现在PHP中使用Kafka，具体包括扩展安装和这种方式的基本操作，感兴趣的小伙伴可以跟随小编一起学习一下
- 日期：2022-06-14
- 浏览：67
- 标签： PHP
-
- CentOS7上如何安装Kafka?CentOS7上安装Kafka教程
- Kafka 是一种高吞吐的分布式发布订阅消息系统，能够替代传统的消息队列用于解耦合数据处理，缓存未处理消息等。那么CentOS7上如何安装Kafka?下面小编将为大家带来CentOS7上安装Kafka教程！有需要的朋友一起去看看吧
- 日期：2022-06-06
- 浏览：118
排行榜
网公网安备