kubernetes安装kafka

kubernetes安装kafka

使用helm3安装

helm install kafka bitnami/kafka

查看
在这里插入图片描述

使用kafka-client做测试

kubectl exec --tty -i kafka-client --namespace default -- bash

测试启动消费者

kafka-console-consumer.sh \
    --bootstrap-server kafka.default.svc.cluster.local:9092 \
    --topic test \
    --from-beginning

生产者

kafka-console-producer.sh \
--broker-list kafka-0.kafka-headless.default.svc.cluster.local:9092 \
--topic test

输入hello word ,测试消息通信
在这里插入图片描述

查看topic状态

kafka-configs.sh --bootstrap-server 10.108.77.12:2181 --describe --entity-type topics --entity-name test

修改消息过期时间

kafka-configs.sh --bootstrap-server kafka-zookeeper.default.svc.cluster.local:2181 --entity-type topics --entity-name test --alter --add-config retention.ms=10000

retention.ms=10000设定消息过期时间为10秒,过期后消息会自动删除

删除topic

kafka-topics.sh --delete --topic test --zookeeper kafka-zookeeper.default.svc.cluster.local:2181
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/100333.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • SQL Server 2005“备份集中的数据库备份与现有的数据库不同”解决方法

    SQL Server 2005“备份集中的数据库备份与现有的数据库不同”解决方法以前一直使用SQLServer2000,现在跟潮流都这么紧,而且制定要求使用SQLServer2005,就在现在的项目中使用它了。 对于SQLServer2005,有几个地方是要注意的,比方在还原数据库时,不像2000里边将数据库和文件区分的很细,统一均为文件,这就使还原的数据库文件制定为.bak。那么想还原2000的数据库(备份数据库文件,无后缀名的),就需要自己手工选择。

  • 但是,在通过移动数组的上升周期中找到指定元素

    但是,在通过移动数组的上升周期中找到指定元素

  • SqlServer时间与字符串相互转换[通俗易懂]

    SqlServer时间与字符串相互转换[通俗易懂]convert(目标类型[datatime/varchar],’输入内容'[时间/字符串],格式); –字符串转为时间类型(当表字段为时间格式时使用) –1.Style=101时,表示日期字符串为:mm/dd/yyyy格式SELECTCONVERT(datetime,’11/1/2003′,101)–结果:2003-11-0100:00:00.000应用:…

  • 2017 主流手机分辨率与尺寸

    2017 主流手机分辨率与尺寸主流手机分辨率与尺寸1、小米小米1:  480×854   4.0英寸小米2:  720×1280  4.3英寸小米3:  1080×1920 5.0英寸小米4:  1080×1920 5.0英寸小米note:1080×1920 5.7英寸2、华为华为p7: 

  • python for跳过下一个循环_python循环三次跳出循环

    python for跳过下一个循环_python循环三次跳出循环python中如何退出for循环Python中的for循环与其它语言不大一样,但跳出循环还是与大多数语言一样,可以使用关键字continue跳出本次循环或者break跳出整个for循环。break语句:Python中的break语句,就像在C语言中,打破了最小封闭for或while循环。break语句用来终止循环语句,即循环条件没有False条件或者序列还没被完全递归完,也会停止执行循环语句。br…

  • vue中父组件向子组件传值

    vue中父组件向子组件传值首先在以下案例中,App.vue是父组件,Second-module.vue是子组件。总体来说,父传子就是这四个步骤:父组件的data中定义值,引入并调用子组件,在引用的子组件的标签上通过v-bind指令给子组件传值,子组件通过在data中定义的props属性接收父组件传过来的值然后应用到子组件里。首先,值肯定是定义在父组件中的,供所有子组件共享,所以要在父组件的data中定义值:…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号