搜索结果
查询Tags标签： kafka，共有 918条记录-
Linux简单的运行脚本
配置集群hostname（要先在host文件中配置了ip和名字的映射，才能使用脚本） 配置hostname文件在每台机器执行命令 echo hostname1 > /etc/hostnamehostname hostname1 备注：hostname1 为主机名，最好能标识主机用途，例如：kafkaos1、kafkaos2。 配置hosts文件 修改完…
2021/8/31 7:06:19 人评论 次浏览 -
spring boot项目12：Kafka-基础使用
JAVA 8 Spring Boot 2.5.3 kafka_2.13-2.8.0 apache-zookeeper-3.7.0 ---授人以渔： 1、Spring Boot Reference Documentation This document is also available as Multi-page HTML, Single page HTML and PDF. 有PDF版本哦，下载下来！ 2、Spring for Apache Kafka 有PD…
2021/8/30 6:06:15 人评论 次浏览 -
spring boot项目12：Kafka-基础使用
JAVA 8 Spring Boot 2.5.3 kafka_2.13-2.8.0 apache-zookeeper-3.7.0 ---授人以渔： 1、Spring Boot Reference Documentation This document is also available as Multi-page HTML, Single page HTML and PDF. 有PDF版本哦，下载下来！ 2、Spring for Apache Kafka 有PD…
2021/8/30 6:06:15 人评论 次浏览 -
windows docker 安装kafka
docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper 运行zookeeper 出现以下错误提示时：docker: Error response from daemon: Ports are not available: listen tcp 0.0.0.0:2181: bind: An attempt was made to access a socket in a way forbidd…
2021/8/29 7:08:22 人评论 次浏览 -
windows docker 安装kafka
docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper 运行zookeeper 出现以下错误提示时：docker: Error response from daemon: Ports are not available: listen tcp 0.0.0.0:2181: bind: An attempt was made to access a socket in a way forbidd…
2021/8/29 7:08:22 人评论 次浏览 -
Kafka 使用-安装
Kafka 使用-安装 官方网站http://kafka.apache.org/ 官方文档Kafka 是什么？Apache Kafka is an open-source distributed event streaming platform used by thousands of companies for high-performance data pipelines, streaming analytics, data integration, and m…
2021/8/29 6:08:15 人评论 次浏览 -
Kafka 使用-安装
Kafka 使用-安装 官方网站http://kafka.apache.org/ 官方文档Kafka 是什么？Apache Kafka is an open-source distributed event streaming platform used by thousands of companies for high-performance data pipelines, streaming analytics, data integration, and m…
2021/8/29 6:08:15 人评论 次浏览 -
Kafka的工作原理及过程
一、Broker启动当每个 broker 启动时，会在 ZooKeeper 中的 /brokers/ids 路径下创建⼀个节点来注册⾃⼰，节点 ID 为配置⽂件中的 broker.id 参数，后注册的 broker 会报 NodeExists 的错。如果不指定 broker.id 或者指定成 -1，节点 ID 会从 reserved.broker.max.id 这个…
2021/8/27 6:09:12 人评论 次浏览 -
Kafka的工作原理及过程
一、Broker启动当每个 broker 启动时，会在 ZooKeeper 中的 /brokers/ids 路径下创建⼀个节点来注册⾃⼰，节点 ID 为配置⽂件中的 broker.id 参数，后注册的 broker 会报 NodeExists 的错。如果不指定 broker.id 或者指定成 -1，节点 ID 会从 reserved.broker.max.id 这个…
2021/8/27 6:09:12 人评论 次浏览 -
腾讯大牛教你ClickHouse实时同步MySQL数据
ClickHouse作为OLAP分析引擎已经被广泛使用，数据的导入导出是用户面临的第一个问题。由于ClickHouse本身无法很好地支持单条大批量的写入，因此在实时同步数据方面需要借助其他服务协助。本文给出一种结合Canal+Kafka的方案，并且给出在多个MySQL实例分库分表的场景下，如…
2021/8/25 19:06:08 人评论 次浏览 -
腾讯大牛教你ClickHouse实时同步MySQL数据
ClickHouse作为OLAP分析引擎已经被广泛使用，数据的导入导出是用户面临的第一个问题。由于ClickHouse本身无法很好地支持单条大批量的写入，因此在实时同步数据方面需要借助其他服务协助。本文给出一种结合Canal+Kafka的方案，并且给出在多个MySQL实例分库分表的场景下，如…
2021/8/25 19:06:08 人评论 次浏览 -
kafka创建topic报错
kafka执行如下创建topic的语句： [root@node01 kafka_2.11-1.0.0]# bin/kafka-topics.sh --create --topic streaming-test --replication-factor 1 --partitions 3 --zookeeper node01:2181,node02:2181,node03:2181Error while executing topic command : Replication f…
2021/8/24 6:06:02 人评论 次浏览 -
kafka创建topic报错
kafka执行如下创建topic的语句： [root@node01 kafka_2.11-1.0.0]# bin/kafka-topics.sh --create --topic streaming-test --replication-factor 1 --partitions 3 --zookeeper node01:2181,node02:2181,node03:2181Error while executing topic command : Replication f…
2021/8/24 6:06:02 人评论 次浏览 -
JAVA大厂面试题
并发 锁升级过程，轻量锁可以变成偏向锁么，偏向锁可以变成无锁么，自旋锁，对象头结构，锁状态变化过程JVM jvm类加载器，自定义类加载器，双亲委派机制，优缺点，tomcat类加载机制 cms收集器过程，g1收集器原理，怎么实现可预测停顿的，region的大小，结构 jvm了解哪些参…
2021/8/23 14:05:35 人评论 次浏览 -
JAVA大厂面试题
并发 锁升级过程，轻量锁可以变成偏向锁么，偏向锁可以变成无锁么，自旋锁，对象头结构，锁状态变化过程JVM jvm类加载器，自定义类加载器，双亲委派机制，优缺点，tomcat类加载机制 cms收集器过程，g1收集器原理，怎么实现可预测停顿的，region的大小，结构 jvm了解哪些参…
2021/8/23 14:05:35 人评论 次浏览
