Kafka生产者和消费者相关命令行操作

雨点打透心脏的1/2处 2023-10-18 21:40 23阅读 0赞

启动kafka： bin/kafka-server-start.sh config/server.properties &

1，开启zookeeper集群 startzk.sh
    2，开启kafka集群  start-kafka.sh
    2，开启kafka可视化界面 kafka-manager ： start-kafka-manager.sh
     
    3,生产者操作：
    kafka-console-producer.sh --broker-list node1:9092 --topic my-kafka-topic    //my-kafka-topic时topic的名字
     
    4,消费者操作：
    kafka-console-consumer.sh --bootstrap-server node1:9092 --topic my-kafka-topic
    # 通过以上命令，可以看到消费者可以接收生产者发送的消息
     
    # 如果需要从头开始接收数据，需要添加--from-beginning参数
    kafka-console-consumer.sh --bootstrap-server node01:9092 --from-beginning --topic my-kafka-topic
     
     
    5,a.创建topic
    kafka-topics.sh --create --zookeeper node1:2181 --replication-factor 1 --partitions 1 --topic my-kafka-topic
     
    b.查看topic列表
    kafka-topics.sh --list --zookeeper node01:2181
     
    c.如果需要查看topic的详细信息，需要使用describe命令
    kafka-topics.sh --describe --zookeeper node1:2181 --topic test-topic
     
    d.#若不指定topic，则查看所有topic的信息
    kafka-topics.sh --describe --zookeeper node1:2181
     
    e.删除topic
    kafka-topics.sh --delete --zookeeper node1:2181 --topic my-kafka-topic

1,查看指定group消费情况
    bin/kafka-consumer-groups.sh --bootstrap-server 172.17.6.10:9092 --describe --group group-1

发表评论取消回复

表情：

评论列表（有 0 条评论，23人围观）

还没有评论，来说两句吧...

相关阅读

相关 Kafka建立生产者消费者

Kafka 是一个分布式流处理平台，可以用于构建高效的消息系统。在 Kafka 中，消息的产生和消费分别由生产者（Producer）和消费者（Consumer）来完成。以...

刺骨的言语ヽ痛彻心扉/ 2024年04月21日 19:24/ 0 赞/ 44 阅读

相关 Kafka 生产者和消费者实例

> 目录 > > 一、基于命令行使用Kafka > > 二、创建一个名为“itcasttopic”的主题 > > ①、创建生产者 > > ②、创建消费者 > > ③、

爱被打了一巴掌/ 2024年04月06日 10:11/ 0 赞/ 56 阅读

相关 Kafka生产者和消费者相关命令行操作

启动kafka： bin/kafka-server-start.sh config/server.properties & 1，开启zookeeper集群 s

雨点打透心脏的1/2处/ 2023年10月18日 21:40/ 0 赞/ 24 阅读

相关大数据-消息队列-Kafka(四)：Kafka命令行操作【Topic(主题)、Producer(生产者)、Consumer(消费者)】

![1c4ca1f23e3043db9243c9866d8b6f6a.png][] 一、Topic(主题)命令行操作 1. 查看操作主题命令需要的参数 [

た入场券/ 2023年10月08日 23:27/ 0 赞/ 19 阅读

相关 Kafka生产者和消费者的工作原理

探究Kafka生产者的工作原理主题和日志对于每个主题，Kafka群集都会维护一个分区日志，如下所示： ![在这里插入图片描述][watermark_type

冷不防/ 2022年11月25日 00:41/ 0 赞/ 193 阅读

相关 kafka生产者、消费者消息操作命令

sender： ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5a

ゞ浴缸里的玫瑰/ 2022年09月11日 06:21/ 0 赞/ 170 阅读

相关 kafka 生产者和消费者实例

一、环境安装配置 1、去[官网][Link 1]下载kafka 我下载的版本是 kafka\_2.11-0.10.0.1.tgz，下面的实例也是基于该版本。 2、解压安装

爱被打了一巴掌/ 2022年07月16日 01:47/ 0 赞/ 242 阅读

相关 Java测试Kafka生产者和消费者

一、环境准备请看上篇文章介绍[kafka的部署与安装][kafka]，安装成功之后，启动kafka。在Gradle中引入kafka-client依赖 co

- 日理万妓/ 2022年05月23日 13:56/ 0 赞/ 247 阅读

相关 Kafka的生产者消费者Java操作示例

本文提供Java对Kafka生产者、消费者操作的简单示例： 1.首先看下pom依赖： <dependency> <groupId>org.apache

淩亂°似流年/ 2022年05月18日 10:09/ 0 赞/ 195 阅读

相关 kafka生产者消费者java

1、HDP EpointKafkaUtil.java package com.epoint.core.utils.hadoop; import

深碍√TFBOYSˉ_/ 2022年02月13日 14:19/ 0 赞/ 292 阅读