搜索结果
查询Tags标签： topic，共有 206条记录-
源码实践_实现一个mqtt(2)
目录源码实践_实现一个mqtt(2)topic和tcp连接的关系btreetopic节点代码 源码实践_实现一个mqtt(2)订阅， 发布， tcp数据结构选型topic和tcp连接的关系查找topic快此时没考虑topic匹配，只是考虑定义好直接写死发送消息快让topic维护tcp，找到topic，官博即可btree 之前看…
2021/9/3 17:07:26 人评论 次浏览 -
基于Windows的Kafka自学笔记
环境：Windows10 安装kafka： Step1. 基于JDK Step2. 安装Zookeeper，https://zookeeper.apache.org/releases.html 下载ZooKeeper，目前最新的稳定版本为 3.4.8 版本，用户可以自行选择一个速度较快的镜像来下载即可；启动：在Windows环境下，直接双击zkServer.cmd即可（…
2021/9/2 7:07:34 人评论 次浏览 -
基于Windows的Kafka自学笔记
环境：Windows10 安装kafka： Step1. 基于JDK Step2. 安装Zookeeper，https://zookeeper.apache.org/releases.html 下载ZooKeeper，目前最新的稳定版本为 3.4.8 版本，用户可以自行选择一个速度较快的镜像来下载即可；启动：在Windows环境下，直接双击zkServer.cmd即可（…
2021/9/2 7:07:34 人评论 次浏览 -
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 人评论 次浏览 -
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 人评论 次浏览 -
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 人评论 次浏览 -
搭建kafka
Kafka 被称为下一代分布式消息系统，由 scala 和 Java 编写，是非营利性组织 ASF(Apache Software Foundation，简称为 ASF)基金会中的一个开源项目，比如 HTTP Server、Hadoop、ActiveMQ、Tomcat 等开源软件都属于 Apache 基金会的开 源软件，类似的消息系统还有 RbbitMQ…
2021/8/20 23:09:04 人评论 次浏览 -
搭建kafka
Kafka 被称为下一代分布式消息系统，由 scala 和 Java 编写，是非营利性组织 ASF(Apache Software Foundation，简称为 ASF)基金会中的一个开源项目，比如 HTTP Server、Hadoop、ActiveMQ、Tomcat 等开源软件都属于 Apache 基金会的开 源软件，类似的消息系统还有 RbbitMQ…
2021/8/20 23:09:04 人评论 次浏览 -
SQL之行转列
例题：如何将逗号分隔的一行数据变成多行 例如表格如下： 需要转换的结果如下： 转换的SQL语句如下：select substring_index(substring_index(a.userIds,,,b.help_topic_id+1),,,-1) as id, substring_index(substring_index(a.userNames,,,b.help_topic_id+1),,,-1) us…
2021/8/13 2:07:14 人评论 次浏览 -
SQL之行转列
例题：如何将逗号分隔的一行数据变成多行 例如表格如下： 需要转换的结果如下： 转换的SQL语句如下：select substring_index(substring_index(a.userIds,,,b.help_topic_id+1),,,-1) as id, substring_index(substring_index(a.userNames,,,b.help_topic_id+1),,,-1) us…
2021/8/13 2:07:14 人评论 次浏览 -
50个kafka常见面试题及答案，撸完阿里P7见，小米Java社招面试
不正确，通过自定义分区分配策略，可以将一个consumer指定消费所有partition。 11. 消费者提交消费位移时提交的是当前消费到的最新消息的offset还是offset+1? offset+1 12. 有哪些情形会造成重复消费？ 消费者消费后没有commit offset(程序崩溃/强行kill/消费耗时/自动提…
2021/8/7 20:06:33 人评论 次浏览 -
50个kafka常见面试题及答案，撸完阿里P7见，小米Java社招面试
不正确，通过自定义分区分配策略，可以将一个consumer指定消费所有partition。 11. 消费者提交消费位移时提交的是当前消费到的最新消息的offset还是offset+1? offset+1 12. 有哪些情形会造成重复消费？ 消费者消费后没有commit offset(程序崩溃/强行kill/消费耗时/自动提…
2021/8/7 20:06:33 人评论 次浏览
