# 修改每个topic的默认分区参数num.partitions，默认是1，具体合适的取值需要根据服务器配置进程确定，UCloud.ukafka = 3. Segment：partition物理上由多个segment组成，下面2.2和2.3有详细说明。pa

新建一个graph，使用典型的生产者-消费者模型：将Data Generator生成的数据交给kafka Producer operator；而Kafka Consumer从kafka producer里读取出data Generator生成的数据，通过T

2.需要先启动ZooKeeper服务器(可以通过与kafka打包在一起的便捷脚本来快速简单地创建一个单节点ZooKeeper实例。

#3个节点集群使用，分别在节点1 2 3执行该脚本即可。# 重点 Type 必须为 forking 否则无法启动，

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

进入redis命令 ps -ef | grep redis 查看redis服务是否开启 如果开启可以直接 redis-cli -h 192.168.107.128 -p 6379 进到redis的bin目录下执行 这个是开启redis服

在上文中介绍了如何搭建一个Kafka服务，那么在开发中我们要如何去访问、集成Kafka呢？这就需要使用到本文将要介绍的Kafka客户端API。AdminClient API：允许管理和检测Topic、broker以及其他Kafka实例，与Kafka自带的脚

答案就是 Topic 级别参数会覆盖全局 Broker 参数的值，而每个 Topic 都能设置自己的参数值，这就是所谓的 Topic 级别参数。retention.ms：规定了该 Topic 消息被保存的时长。retention.bytes：规定了要为该

> bin/kafka-topics.sh --create --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181 --replication-factor 1 --partitions 1 --top

通过命令查 ./bin/kafka-consumer-groups.sh --bootstrap-server ip:9092 --describe --group consumer2. 保存到 kafka配置的~/data文件夹(现有集群为3/分析得出就

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 -partitions 1 --topic test

近期在研究各种消息队列方案，为了有一个直观的使用体验，我把Kafka，RocketMQ，RabbitMQ各自部署了一遍，并使用了最基本的生产与消费消息功能。在部署过程中也遇到一些问题，特此记录。本文只适用于没有使用过消息队列，还停留在安装部署阶段的新手用户

如果没有安装，请先安装java环境 参考JDK安装方法 ?默认情况下，每行将作为单独的消息发送。运行生产者，然后在控制台中键入一些消息以发送到服务器。

　　消息生产者，发布消息到 kafka 集群的终端或服务。　　每条发布到 kafka 集群的消息属于的类别，即 kafka 是面向 topic 的。　　partition 是物理上的概念，每个 topic 包含一个或多个 partition。kafka 分

Zookeeper集群共三台服务器，分别为：sto1、sto2、sto3。kafka是一个分布式消息队列，需要依赖ZooKeeper，请先安装好zk集群。broker.id=0 #参考zookeeper的myid ，每个id不能一样，0，1，2集群中

bin/kafka-topics.sh --create --zookeeper localhost:2181 --topic test_topic --replication-factor 3 --partitions 10 --config clean

创建topic话题bin/kafka-topics.sh --create --topicnews（话题名） --bootstrap-server 192.168.79.137:9092 -partitions（分区） 3 -replication-fac

kafka 相关的知识进入 /usr/local/kafka 目录下查看端口 vim zookeeper.properties #文件中dataDir=/tmp/zookeeper代表zookeeper数据存储路径，clientPort=218

　　本文记录一下kafka多机多Broker（集群）的基本配置，在上篇的基础上进行，上篇配置在192.168.7.151上，本篇在152上。　　2、删除掉logs中的旧文件broker0、broker1，并且新建broker2、broker3. 　　3、修

kafka-topics.sh --create --zookeeper master:2181,master-backup:2181 --topic sendTopic --partitions 2 --replication-factor 1