linux安装java https://www.cnblogs.com/liugh/p/6623530.html https://download.oracle.com/otn-pub/java/jdk/8u201-b09/42970487e3af4f5aa5bca3f542482c60/jdk-8u201-linux-x64.tar.gz /home/user/wz/jdk1.8.0_201 #Java Env export JAVA_HOME=/usr/jdk1.8.0_121 export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar export PATH=$PATH:$JAVA_HOME/bin 单机配置zookeeper https://www.cnblogs.com/lsdb/p/7297731.html mkdir data mkdir logs 在conf目录下新建zoo.cfg文件，写入以下内容保存： tickTime=2000 dataDir=/home/user/wz/zookeeper-3.5.4-beta/data dataLogDir=/home/user/wz/zookeeper-3.5.4-beta/logs clientPort=2181 进入bin目录，启动、停止、重启分和查看当前节点状态（包括集群中是何角色）别执行： ./zkServer.sh start ./zkServer.sh stop ./zkServer.sh restart ./zkServer.sh status ----------------------------------------------------------- 下载Binary包 https://www.apache.org/dyn/closer.cgi?path=/kafka/2.1.0/kafka_2.11-2.1.0.tgz bin/kafka-server-start.sh config/server.properties & # 下面命令需要在logs目录下创建个1.log文件，nohub使关闭 shell 后进程还运行 nohup bin/kafka-server-start.sh config/server.properties >logs/1.log 2>&1 & java.nio.file.NoSuchFileException: config/server.properties 只能从bin目录上一级运行，否则找不到config下的配置 ----------------------------------- 使用 -1. 查看帮助信息 bin/kafka-topics.sh --help -2. 创建Topic bin/kafka-topics.sh --create --topic test0 --zookeeper 127.0.0.1:2181 --config max.message.bytes=12800000 --config flush.messages=1 --partitions 5 --replication-factor 1 --create ： 指定创建topic动作 --topic ：指定新建topic的名称 --zookeeper ： 指定kafka连接zk的连接url，该值和server.properties文件中的配置项{zookeeper.connect}一样 --config ：指定当前topic上有效的参数值，参数列表参考文档为: Topic-level configuration --partitions ：指定当前创建的kafka分区数量，默认为1个 --replication-factor ：指定每个分区的复制因子个数，默认1个 -3. 查看当前Kafka集群中Topic的情况 bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181 -4. 查看对应topic的描述信息 bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181 --topic test0 -5. Topic信息修改 bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test0 --config max.message.bytes=128000 bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test0 --delete-config max.message.bytes bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test0 --partitions 10 bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test0 --partitions 3 ## Kafka分区数量只允许增加，不允许减少 -6. Topic删除 bin/kafka-topics.sh --delete --topic test0 --zookeeper 127.0.0.1:2181 启动生产者，往"test0"这个Topic中发送消息： bin/kafka-console-producer.sh --topic test0 --broker-list 127.0.0.1:9092 启动消费者，从"test0"这个Topic中消费消息，其中"--from-beginning"为可选参数，表示要从头消费消息： bin/kafka-console-consumer --bootstrap-server localhost:9092 --topic test0 --from-beginning ------------------------------------- golang配置 go get github.com/Shopify/sarama go get github.com/bsm/sarama-cluster
以上所述就是小编给大家介绍的《golang kafka 1》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！
猜你喜欢:
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
