springboot Spring Boot 项目中集成 Kafka 和 Flink：构建实时数据流处理系统
导语：在现代数据处理中，Spring Boot 项目集成 Kafka 和 Flink 流处理框架是实现实时数据处理和分析的关键。本文将为您介绍具体步骤和相关代码，帮...
中间件 kakfa可视化工具Offset Explorer/kafka-Tool 的使用
前言当要读取kafka 中的数据时，在服务器上查看比较麻烦，数据量较大，也不是很直观。此时就需要一款简洁，使用方便的可视化工具了，嘻嘻， Offset Explorer （以前叫：kafka-Tool ） 就是一...
java java8下spark-streaming结合kafka编程（spark 2.3 kafka 0.10）
前面有说道spark-streaming的简单demo，也有说到kafka成功跑通的例子，这里就结合二者，也是常用的使用之一。 1.相关组件版本 首先确认版本，因为跟之前的版本有些不一样，所以才有必要记录...
spring springboot+kafka+sparkstreaming 生产及消费数据-超简单实例
springboot+kafka+sparkstreaming 生产及消费数据-超简单实例 kafka生产者实例： import org.apache.kafka.clients.producer.Callback;import org.apache.kafka.clients.producer.KafkaProd...
java java8下spark-streaming结合kafka编程（spark 2.3 kafka 0.10）
前面有说道spark-streaming的简单demo，也有说到kafka成功跑通的例子，这里就结合二者，也是常用的使用之一。 1.相关组件版本 首先确认版本，因为跟之前的版本有些不一样，所以才有必要记录...
kafka Spark 2.1.2 Streaming + Kafka 1.1.0 -- 在IDEA中通过Maven创建Spark项目
一、开发环境中需要安装和配置如下安装JDK，配置JDK环境变量(jdk1.8)安装Scala，配置JDK环境变量(scala2.11.8)最好安装一个Maven,虽然Idea已经集成自带的有Maven测试环境中已经安装有Zookeep...
java Kafka学习（三）——Java工具类、Springboot集成批量消费、SparkStreaming集成
前言本次记录全部来自工作学习中，总结和测试。并非生产环境，仅供参考使用！ 提示：以下是本篇文章正文内容，下面案例可供参考 一、Java中工具类常用于测试使用~ 1. 添加maven依赖<depen...
kafka CentOS 7 安装配置 kafka，并配置开机自启（systemctl）
安装 kafka 需要先安装 jdk。一、下载官网：http://kafka.apache.org/downloads.html 二、安装 安装参考：https://segmentfault.com/a/1190000012990954 1. 解压安装（...
kafka kafka官方的kafka-server-start.sh不能关闭kafka进程解决办法
vi kafka-server-stop.sh 把PIDS=$(ps ax | grep -i 'kafka\.Kafka' | grep java | grep -v grep | awk '{print $1}')这行代码修改为 PIDS=$(jps -lm | grep -i 'kafka.Kafka' | awk...