zoukankan      html  css  js  c++  java
  • run kafka local

    Q: How to run kafka local
    download kafka http://kafka.apache.org/downloads

    start zookeeper
    $ bin/zookeeper-server-start.sh config/zookeeper.properties
    start kafka
    $ bin/kafka-server-start.sh config/server.properties
    or JMX_PORT=9988 bin/kafka-server-start.sh -daemon config/server.properties
    start kafka producer
    $ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topicName
    start kafka consumer
    $ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --from-beginning --consumer-property group.id=test-group
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --from-beginning --consumer-property group.id=test-group --isolation-level read_committed
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --consumer-property group.id=test-group
    cat kafka-consumer-groups
    bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
    describe kafka-consumer-group
    bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-group
    describe topic
    bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic topicName
    delete topic
    bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic topicName
    create topic
    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic topicName
  • 相关阅读:
    无法往u盘里边复制超过4G的单个文件解决方法
    vue 自定义属性判断点击每个item 显示隐藏
    前端小组分享会之异步回调函数中的上下文
    git 的一些命令
    ES学习之promise
    mac找到占用端口号的进程ID
    meta link
    webpack学习笔记--安装
    css样式之 direction
    日常积累之JSON.stringify和JSON.parse substr
  • 原文地址:https://www.cnblogs.com/tonggc1668/p/15246740.html
Copyright © 2011-2022 走看看