kafka2.5.0基本命令(代码片段)

zhuwenjoyce zhuwenjoyce     2022-11-29     438

关键词:

1)启动zookeeper

演示用的话,直接启动kafka自带的zookeeper即可:

cd kafkaDirectory/kafka_2.12-2.5.0
bin/zookeeper-server-start.sh config/zookeeper.properties

生产上建议连接到zookeeper集群,需更改配置文件 config/server.properties 里更改zookeeper配置zookeeper.connect=localhost:2181

2) 启动kafka server

cd kafkaDirectory/kafka_2.12-2.5.0
bin/kafka-server-start.sh config/server.properties

 3) 主题topic

 创建topic : test

bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

列出topic:

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

往test Topic里发送数据:

bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

从test Topic里面从头开始消费数据:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

 

 

 

end.

 

 

kafka2.5.0自定义分区器(代码片段)

自定义分区器:importorg.apache.kafka.clients.producer.Partitioner;importorg.apache.kafka.common.Cluster;importorg.apache.kafka.common.PartitionInfo;importjava.util.List;importjava.util.Map;/***@authorKing老师* 查看详情

kafka2.5.0详解核心配置文件server.properties(代码片段)

$cat-nconfig/server.propertiesbroker.id=0    //brokerID, 集群模式下该ID必须唯一,且永恒不变 listeners=PLAINTEXT://your_host_name:9092    // 配置你的应用所在IP地址,我理解为访问白名 查看详情

kafka2.5.0生产者与消费者配置详解(代码片段)

1)引入maven依赖我这里使用的是springboot2.1.3.RELEASE 版本:<dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId></dependency>会引入一对的ka 查看详情

kafka2.5.0自定义数据序列化类(代码片段)

kafka只接收bytes字节数组,所以自定义序列化器内部实现需按照bytes字节数组转换为标准。重点:本例子只是提供参考怎样写自定义序列化器,因为关系到性能,一般默认使用StringSerializer即可,效率很高。小知识:Kafka支持Avro序... 查看详情

kafka2.5.0硬件集群架构图topic主题与partitions分区架构图

 kafkaTopic主题与Patitions分区架构图:  硬件架构图: end. 查看详情

kafka2.5.0架构硬件选择参考因素

Kafka架构在硬件选择方面,以重要性顺序考虑以下4点:1) 磁盘(最重要)。影响最大的事生产者,读写速度。需参考多个分区、多个目录,如一个分区每天生产1TB数据,10天就是10GB,再乘以分区数量。2)网络。生产者、消费... 查看详情

pythonnumpy基本命令(代码片段)

查看详情

text基本命令行(代码片段)

查看详情

docker常用基本命令(代码片段)

文章目录基本命令参考资料本文主要介绍Docker常用的基本命令。基本命令查看Docker版本dockerversion查看Docker状态systemctlstatusdocker启动Dockersystemctlstartdocker重启dockersystemctlrestartdocker查看本地已有镜像dockerimages设置仓库vim/etc/docker/daemo... 查看详情

docker常用基本命令(代码片段)

文章目录基本命令参考资料本文主要介绍Docker常用的基本命令。基本命令查看Docker版本dockerversion查看Docker状态systemctlstatusdocker启动Dockersystemctlstartdocker重启dockersystemctlrestartdocker查看本地已有镜像dockerimages设置仓库vim/etc/docker/daemo... 查看详情

docker常用基本命令(代码片段)

文章目录基本命令参考资料本文主要介绍Docker常用的基本命令。基本命令查看Docker版本dockerversion查看Docker状态systemctlstatusdocker启动Dockersystemctlstartdocker重启dockersystemctlrestartdocker查看本地已有镜像dockerimages设置仓库vim/etc/docker/daemo... 查看详情

git常用基本命令(代码片段)

文章目录基本命令仓库相关命令提交相关命令分支相关命令tag相关命令撤销相关命令IDEAGit相关操作仓库相关操作提交相关操作提交代码步骤分支相关操作tag相关操作撤销相关操作参考资料本文主要介绍Git常用的基本命令。基本... 查看详情

text基本mysql命令(命令行/终端)(代码片段)

查看详情

text基本git命令(代码片段)

查看详情

r[基本r命令](代码片段)

查看详情

composer基本命令(代码片段)

composer基本命令composerinit(-q)利用composer创建新应用composerinit-qcomposerrequire和composerinstallcomposerrequireguzzlehttp/guzzle//安装guzzlecomposerinstall需要配合composer.json使用直接在命令行下编辑composer.json"require& 查看详情

javascript基本的mongoose命令(代码片段)

查看详情

text基本的docker命令(代码片段)

查看详情