如何快速优雅的用Know Streaming创建Topic

2024-05-14 08:27:17

文章目录

操作流程
操作亮点
- 配置清理策略
- 测试消息大小
- 更多定制化属性配置

操作流程

①、点击新增Topic

②、填写Topic的基本信息和配置

③、点击确认、创建成功！

操作亮点

简单清晰的操作界面, 让你能够非常快速的创建一个新的Topic；
除了这个基本的功能外,你还可以看到在这里能够针对每个Topic做更细粒度的定制化配置。

配置清理策略

默认情况下, 普通Topic的清理策略为 delete , 而 __consumer_offset的默认清理策略为compact

delete : 过期则直接把消息删除

compact: 消息紧缩, 如果消息key相同的话，那么value的值就是最近最新的一条。比如说__consumer_offset这个是记录消费组消费的偏移量的信息。同一个消费组消费某个TopicPartition的时候,会把offset消息写入到这个Topic中，每次写入的Key是一样的，但是Value不一样。那获取当前消费组消费的Offset信息的时候，读取的就是这个Key最新的一条。并且消息过期清理的话会把之前的删掉。

测试消息大小

想设置这个Topic的指定大小, 但是却又不知道消息大概有多大？

没事, Know Streaming 为你提供了计算的窗口

把你的消息体负责到这里面，就会自动展示给你占用的字节数，让你在配置参数属性的时候能够有一个依据。

更多定制化属性配置

这下面的配置,都只是针对的该Topic生效的, 并且这里配置的属性都是属于动态配置。

关于什么是动态配置可以看：【kafka】kafka的动态配置管理使用和分析

如何快速优雅的用Know Streaming创建Topic相关推荐

如何快速优雅地导入第三方Android项目
**丨**版权说明 : <如何快速优雅地导入第三方Android项目>于当前CSDN博客和乘月网属同一原创,转载请说明出处,谢谢. 最近有很多朋友都在向我抱怨导入第三方项目遇到各种各样的问 ...
如何快速优雅的在CSDN输入公式？
■ 输入公式太难了! 如果你是在别的网站通过BLOG记录自己的工作.生活和学习的话,也许是否输入数学公式无关大碍,毕竟这种理工科学生的语言刻薄.寡味.但在 CSDN 专业网站上来记录理工科专业内容 ...
【Android RTMP】NV21 图像旋转处理 ( 快速搭建 RTMP 服务器 Shell 脚本 | 创建 RTMP 服务器镜像 | 浏览器观看直播 | 前置 / 后置摄像头图像旋转效果展示 )
文章目录安卓直播推流专栏博客总结一. 编写快速搭建 RTMP 服务器 Shell 脚本二. RTMP 快速搭建方法三.创建阿里云 RTMP 服务器镜像四.浏览器查看直播内容五.前置 / 后 ...
PostgreSQL 快速给指定表每个字段创建索引 - 2
标签 PostgreSQL , 索引 , 所有字段 , 并行创建单个索引 , max_parallel_maintenance_workers , 异步调用 , dblink , 并行创建多个索引 , ...
oracle静默创建实例linux,linux CentOS7下快速静默安装Oracle11GR2数据库并创建实例
linux CentOS7下快速静默安装Oracle11GR2数据库并创建实例本文章适合已经熟悉安装过程,需要快速部署使用初学者建议分步学习:https://edu.51cto.com/cours ...
RocketMQ快速入门之手动创建topic
package cn.learn.rocketmq.topic;import org.apache.rocketmq.client.producer.DefaultMQProducer;public ...
RocketMQ3.2.2生产者发送消息自动创建Topic队列数无法超过4个
问题现象 RocketMQ3.2.2版本,测试时尝试发送消息时自动创建Topic,设置了队列数量为8: producer.setDefaultTopicQueueNums(8); 同时设置broker ...
创建topic验证kafka集群
0)'''kafka&zookpeer信息''' zkinfo: 172.18.238.2:2181 172.18.238.3:2181 172.18.238.4:2181 kafkainfo ...
kafka java创建topic_kafkakafka_2.10-0.8.2.1+zookeeper-3.4.6 创建topic一个小问题
kafka 创建topic时出现如下异常: Error while executing topic command org.apache.zookeeper.KeeperException$NoNod ...

最新文章

热门文章