搜索结果
查询Tags标签： 9092，共有 23条记录-
Flink SQl 语法(hint,with,select,分组窗口聚合，时间属性（处理，事件）)
6、Flink SQl 语法 1、查询语句 1、hint在对表进行查询的是偶动态修改表的属性-- 创建表 CREATE TABLE word (lines STRING ) WITH (connector = kafka,topic = word,properties.bootstrap.servers = master:9092,node1:9092,node2:9092,properties.group.id = testGrou…
2022/8/1 2:23:09 人评论 次浏览 -
docker 中安装kafka
docker 中安装kafka 在安装kafka之前需要先安装zookeeper，因为kafka 启动会将元数据保存在 zookeeper 中，zookeeper是一种分布式协调服务，可以再分布式系统中共享配置，协调锁资源，提供命名服务。 zookeeper 安装 1、在docker中拉取zookeeper 镜像docker pull wurstme…
2022/7/14 6:21:32 人评论 次浏览 -
Windows Docker好方便呀呀呀
Windows Docker好方便呀呀呀今天我需要测试自己写的KafKa基础类库，自己需要搭建一个KafKa环境，自己的云主机不能用，电脑也没有开虚拟机，但是想了一下需要在windows电脑安装Kafka 环境好麻烦呀！！！！ 后面想到有Windows for Docker 工具可以解决困惑。安装Hyper-V和开…
2022/6/30 5:22:26 人评论 次浏览 -
kafka 实战 （ELK+kafka）
准备系统IP应用myiddrocker.idCentOS 7 192.168.100.20 Elasticserach+kibana+kafka+zookeeper 1 1CentOS 7 192.168.100.30 Elasticserach+kafka+zookeeper+filebeat+logstash 2 2CentOS 7 192.168.100.40 Elasticserach+kafka+zookeeper+filebeat 3 3先配置好 Elasticse…
2022/4/18 23:43:50 人评论 次浏览 -
Kafka消息队列
之前也学习过消息队列，但一直没有使用的场景，今天项目中遇到了 kafka 那便有了应用场景1. Kafka Kafka 是一个分布式、支持分区，多副本的基于 zookeeper 的消息队列。使用消息队列，是应用 A 将要处理的信息发送到消息队列然后继续下面的任务，需要该信息的应用 B 从消…
2022/1/9 23:34:17 人评论 次浏览 -
Kafka消息队列
之前也学习过消息队列，但一直没有使用的场景，今天项目中遇到了 kafka 那便有了应用场景1. Kafka Kafka 是一个分布式、支持分区，多副本的基于 zookeeper 的消息队列。使用消息队列，是应用 A 将要处理的信息发送到消息队列然后继续下面的任务，需要该信息的应用 B 从消…
2022/1/9 23:34:17 人评论 次浏览 -
Kafka连接服务器异常：Connection to node 0 (/127.0.0.1:9092)
问题： 在服务器本地可以使用命令行参数连接并且进行发布订阅操作，但是使用spring boot连接服务器则不行，会有如下错误： Connection to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available这个问题需要我们修改下kafka的配置文…
2021/12/14 14:18:43 人评论 次浏览 -
Kafka连接服务器异常：Connection to node 0 (/127.0.0.1:9092)
问题： 在服务器本地可以使用命令行参数连接并且进行发布订阅操作，但是使用spring boot连接服务器则不行，会有如下错误： Connection to node 1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available这个问题需要我们修改下kafka的配置文…
2021/12/14 14:18:43 人评论 次浏览 -
各组件命令
【02】Kafka主题的增、删、查增： bin/kafka-topics.sh --create --topic flink_kafka --partitions 3 --replication-factor 2 --bootstrap-server node1:9092,node2:9092,node3:9092删： bin/kafka-topics.sh --delete --topic bigdata01 --bootstrap-server node1:9092…
2021/11/19 6:40:03 人评论 次浏览 -
各组件命令
【02】Kafka主题的增、删、查增： bin/kafka-topics.sh --create --topic flink_kafka --partitions 3 --replication-factor 2 --bootstrap-server node1:9092,node2:9092,node3:9092删： bin/kafka-topics.sh --delete --topic bigdata01 --bootstrap-server node1:9092…
2021/11/19 6:40:03 人评论 次浏览 -
Kafka参数zookeeper和bootstrap-server的区别
假定有3台机，主机名是node1、node2、node3，以创建一个topic为例： 旧版（< v2.2）kafka-topics.sh --zookeeper node1:2181,node2:2181,node3:2181 --create --topic .. 新版（>= v2.2）kafka-topics.sh --bootstrap-server node1:9092 --create --topic .. 其中…
2021/11/7 23:13:56 人评论 次浏览 -
Kafka参数zookeeper和bootstrap-server的区别
假定有3台机，主机名是node1、node2、node3，以创建一个topic为例： 旧版（< v2.2）kafka-topics.sh --zookeeper node1:2181,node2:2181,node3:2181 --create --topic .. 新版（>= v2.2）kafka-topics.sh --bootstrap-server node1:9092 --create --topic .. 其中…
2021/11/7 23:13:56 人评论 次浏览 -
logstash收集日志并写入kafka再到es集群
条件： 有kafka环境 图形架构：环境准备 172.31.2.101 es1 + kibana 172.31.2.102 es2 172.31.2.103 es3 172.31.2.104 logstash1 172.31.2.105 logstash2 172.31.2.41 zookeeper + kafka 172.31.2.42 zookeeper + kafka 172.31.2.43 zookeeper + kafka 172.31.2.107 web1…
2021/10/7 6:13:18 人评论 次浏览 -
logstash收集日志并写入kafka再到es集群
条件： 有kafka环境 图形架构：环境准备 172.31.2.101 es1 + kibana 172.31.2.102 es2 172.31.2.103 es3 172.31.2.104 logstash1 172.31.2.105 logstash2 172.31.2.41 zookeeper + kafka 172.31.2.42 zookeeper + kafka 172.31.2.43 zookeeper + kafka 172.31.2.107 web1…
2021/10/7 6:13:18 人评论 次浏览 -
kafka集群搭建
本文基于kafka2.8.0，下载时需注意kafka有两个版本号以我的举例kafka_2.12-2.8.0，2.12为scala版本号，2.8.0是kafka版本。kafka基于java，需要先把java环境配置好。 1.点击官网kafka下载，将安装文件上传到服务器。 2.将文件解压出三份，分别放入kafka9092，kafka9093，k…
2021/9/30 23:14:27 人评论 次浏览
