首页 > 其他分享 >Kafka的简单使用

Kafka的简单使用

时间:2022-08-27 17:35:24浏览次数:73  
标签:Java -- 使用 kafka AUDIENCE sh 简单 Kafka

下面目的主要是进行简单测试kafka,比如在其他网络中已提供了IP和地址,进行kafka的读取,自已不想再写代码:
环境要求:存在java环境:

1、下载Kafka的程序 https://kafka.apache.org/downloads
2、将代码解压。
3、执行消息命令。
bin/kafka-console-consumer.sh --topic AUDI_APP_AUDIENCE_DEV --from-beginning --bootstrap-server 172.20.133.21:9092
4、执行发送命令。
bin/kafka-console-producer.sh --topic AUDI_APP_AUDIENCE_DEV --bootstrap-server 172.20.133.21:9092

注意:执行过程中会出现找不到Java目录的情况,请确认$JAVA_HOME位置是否正确。
kafka-run-class.sh: line 342: exec: /Library/Java/JavaVirtualMachines/jdk-11.0.10.jdk/Contents/Home/

官网:
https://kafka.apache.org/quickstart

标签:Java,--,使用,kafka,AUDIENCE,sh,简单,Kafka
From: https://www.cnblogs.com/mytechlife/p/16630955.html

相关文章

  • 【MySQL】MySQL8确认哪些参数在使用以及来源
    在MySQL8中,参数可能来自不同的地方,确认有效的参数来自于哪里:SELECT variable_name, variable_sourceASsource, variable_path, set_time, set_userASUSER, set......
  • BOPF 框架的使用, 以output为例。
    1:首先要创建output的bopf对象,打开方式TCODE:BOBF.里面定义output的rootlevel,itemlevel,log及它们的关系。每个节点定义相应的check,determinevalidateclas......
  • MyBatis保姆级理解与使用,动态SQL(核心)
    1. 动态SQL(核心)1.1 简介Mybatis框架的动态SQL技术是一种根据特定条件动态拼装SQL语句的功能,它存在的意义是为了解决拼接SQL语句字符串时的难点问题。比如:我们在多条......
  • RabbitMQ web管理页面正常访问,但是使用程序连接被拒绝
    软件版本Windowsserver2012R2 RabbitMQ版本3.6.14erlang版本20.3问题描述按照安装教程安装后,web管理页面可以正常访问,也可以设置新用户及其权限,端口监听显示正常。......
  • vdoing使用技巧
    Github中文文档演示效果目录页配置---pageComponent:#使用页面组件name:Catalogue#组件名:Catalogue=>目录页组件data:#组件所需数据path:net......
  • WDA学习(24):Context Menu使用
    1.17UIElement:ContextMenu使用本实例测试创建ContextMenu.1.创建Component,View:V_CONTEXT_MENU;2.创建Context节点;创建Node:NODE_TV,Cardinality:1..1;创建Att......
  • WDA学习(25):DateNavigator使用
    1.18UIElement:DateNavigator使用本实例测试创建DateNavigator;1.创建Component,View:V_DATE_NAVIGATOR;2.创建Context节点;创建NODE:NODE_DATENAV,Cardinality:......
  • WDA学习(23):UI Element:Radio Button Group & CheckBox Group使用
    1.16UIElement:RadioButton&CheckBox使用本实例测试RadioButtonGroup,CheckBoxGroup等的使用。注:DropdownByKey,DropdownByIndex使用方式和RadioButtonGroupByKe......
  • DataContext使用事务
    1//必须打开连接,用于事务的创建2if(db.Connection.State==ConnectionState.Closed)db.Connection.Open();3using(DbTrans......
  • 从Hive中使用HQL语句创建DataFrame--常用方式
    默认情况下SparkSession不支持读取Hive中的数据,也不支持操作HQL语法,如果要读取Hive中的数据,需要开启Hive的支持,构建sparkSession的时候调用一个函数enableHiveSupport()......