如何快速优雅的用 Know Streaming 创建 Topic
1 操作流程
①、点击新增 Topic

在这里插入图片描述
②、填写 Topic 的基本信息和配置

在这里插入图片描述
③、点击确认、创建成功!
2 操作亮点
简单清晰的操作界面, 让你能够非常快速的创建一个新的 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的动态配置管理使用和分析
版权声明: 本文为 InfoQ 作者【石臻臻的杂货铺】的原创文章。
原文链接:【http://xie.infoq.cn/article/404f79b7a1d03629dffd7d595】。未经作者许可,禁止转载。
评论