搜索结果
查询Tags标签： kafka，共有 918条记录-
kafka 启停脚本
新建kf.sh 文件 #!/bin/bash case $1 in "start"){for i in Bigdata04 Bigdata05 Bigdata06doecho ---------- kafka $i 启动 ------------ssh $i "/opt/module/kafka/bin/kafka-server-start.sh -daemon /opt/module/kafka/config/server.properties"…
2021/9/30 6:14:01 人评论 次浏览 -
BTAJ面试有关散列（哈希）表的面试题详解，Java技术篇
Kafka源码篇——Kafka快速入门 1.1Kafka简介1.2以Kafka为中心的解决方案1.3 Kafka核心概念1.4搭建Kafka源码环境Kafka源码篇——生产者 2.1 KafkaProducer使用示例2.2 KafkaProducer分析2.3 RecordAccumulator分析2.4 Sender分析Kafka源码篇——消费者 3.1 KafkaConsumer使…
2021/9/29 9:41:10 人评论 次浏览 -
BTAJ面试有关散列（哈希）表的面试题详解，Java技术篇
Kafka源码篇——Kafka快速入门 1.1Kafka简介1.2以Kafka为中心的解决方案1.3 Kafka核心概念1.4搭建Kafka源码环境Kafka源码篇——生产者 2.1 KafkaProducer使用示例2.2 KafkaProducer分析2.3 RecordAccumulator分析2.4 Sender分析Kafka源码篇——消费者 3.1 KafkaConsumer使…
2021/9/29 9:41:10 人评论 次浏览 -
不一样的kafka系列#server服务端详解
服务端参数 zookeeper.connect 该参数指明broker 要连接的ZooKeeper 集群的服务地址（包含端口号），没有默认值，且 此参数为必填工页。可以配置为localhost:2181 ，如果ZooKeeper 集群中有多个节点，则可以用逗 号将每个节点隔开，类似于localhost1 :2181,lo calhost2 :…
2021/9/28 6:14:00 人评论 次浏览 -
不一样的kafka系列#server服务端详解
服务端参数 zookeeper.connect 该参数指明broker 要连接的ZooKeeper 集群的服务地址（包含端口号），没有默认值，且 此参数为必填工页。可以配置为localhost:2181 ，如果ZooKeeper 集群中有多个节点，则可以用逗 号将每个节点隔开，类似于localhost1 :2181,lo calhost2 :…
2021/9/28 6:14:00 人评论 次浏览 -
Kafka+Flink 实现准实时异常检测系统
1.背景介绍 异常检测可以定义为“基于行动者（人或机器）的行为是否正常作出决策”，这项技术可以应用于非常多的行业中，比如金融场景中做交易检测、贷款检测；工业场景中做生产线预警；安防场景做入侵检测等等。 根据业务要求的不同，流计算在其中扮演着不同的角色：既可…
2021/9/27 23:13:10 人评论 次浏览 -
Kafka+Flink 实现准实时异常检测系统
1.背景介绍 异常检测可以定义为“基于行动者（人或机器）的行为是否正常作出决策”，这项技术可以应用于非常多的行业中，比如金融场景中做交易检测、贷款检测；工业场景中做生产线预警；安防场景做入侵检测等等。 根据业务要求的不同，流计算在其中扮演着不同的角色：既可…
2021/9/27 23:13:10 人评论 次浏览 -
Flink 使用 SQL 读取 Kafka 写入到Doris表中
这次我们演示的是整合Flink Doris Connector 到 Flink 里使用，通过Flink Kafka Connector，通过SQL的方式流式实时消费Kafka数据，利用Doris Flink Connector将数据插入到Doris表中。 这里的演示我们是用过Flink SQL Client来进行的， 1. 准备条件 这里我们使用的环境是 …
2021/9/26 19:11:14 人评论 次浏览 -
Flink 使用 SQL 读取 Kafka 写入到Doris表中
这次我们演示的是整合Flink Doris Connector 到 Flink 里使用，通过Flink Kafka Connector，通过SQL的方式流式实时消费Kafka数据，利用Doris Flink Connector将数据插入到Doris表中。 这里的演示我们是用过Flink SQL Client来进行的， 1. 准备条件 这里我们使用的环境是 …
2021/9/26 19:11:14 人评论 次浏览 -
Flink java作为消费者连接虚拟机中的kafka/或本地的kafka，并解决java.net.UnknownHostException报错
kafka的安装与配置请参考：https://blog.csdn.net/weixin_35757704/article/details/120488287 首先在kafka中创建一个topic，名称叫mytesttopic，进入到kafka的目录下，运行： ./bin/kafka-topics.sh --create --topic mytesttopic --replication-factor 1 --partitions …
2021/9/26 17:10:40 人评论 次浏览 -
Flink java作为消费者连接虚拟机中的kafka/或本地的kafka，并解决java.net.UnknownHostException报错
kafka的安装与配置请参考：https://blog.csdn.net/weixin_35757704/article/details/120488287 首先在kafka中创建一个topic，名称叫mytesttopic，进入到kafka的目录下，运行： ./bin/kafka-topics.sh --create --topic mytesttopic --replication-factor 1 --partitions …
2021/9/26 17:10:40 人评论 次浏览 -
Java job interview:项目架构研发58赶集通用的实时统计分析平台设计与实践
先概括一下飞流有四个特点。 第一，释放用户，减少用户开发成本，所以说这个系统是不需要用户编程，只需要登录个网页，点点配置一下，然后等下，数据就出来了。这是很重要的一个点，也是我们想做这个系统的动机。 第二，提供了丰富的分析和统计功能，求和、取平均、最大最…
2021/9/26 11:41:10 人评论 次浏览 -
Java job interview:项目架构研发58赶集通用的实时统计分析平台设计与实践
先概括一下飞流有四个特点。 第一，释放用户，减少用户开发成本，所以说这个系统是不需要用户编程，只需要登录个网页，点点配置一下，然后等下，数据就出来了。这是很重要的一个点，也是我们想做这个系统的动机。 第二，提供了丰富的分析和统计功能，求和、取平均、最大最…
2021/9/26 11:41:10 人评论 次浏览 -
springcloud学习笔记---环境搭建---kafka集群搭建
springcloud学习笔记—环境搭建—kafka集群搭建 1、下载 wget https://dlcdn.apache.org/kafka/3.0.0/kafka_2.12-3.0.0.tgz2、解压 tar -zxvf kafka_2.12-3.0.0.tgz3、修改配置 1、修改zk配置 cd kafka_2.12-3.0.0/config vim zookeeper.properties修改 dataDir=/kafka/…
2021/9/25 23:13:14 人评论 次浏览 -
springcloud学习笔记---环境搭建---kafka集群搭建
springcloud学习笔记—环境搭建—kafka集群搭建 1、下载 wget https://dlcdn.apache.org/kafka/3.0.0/kafka_2.12-3.0.0.tgz2、解压 tar -zxvf kafka_2.12-3.0.0.tgz3、修改配置 1、修改zk配置 cd kafka_2.12-3.0.0/config vim zookeeper.properties修改 dataDir=/kafka/…
2021/9/25 23:13:14 人评论 次浏览
