关键词:
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& 查看详情