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

迷南。 2024-04-01 10:33 44阅读 0赞

#### 文章目录 ####

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

### 操作流程 ###

①、点击新增Topic

![在这里插入图片描述][480fd222d29a43d5a48cf8b73e1d6a07.png]

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

![在这里插入图片描述][35d95774c5bf49869cb67a6012a0f1d3.png]

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

### 操作亮点 ###

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

#### 配置清理策略 ####

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

![在这里插入图片描述][6fc77a11c3ad446a82b7a5eb425ab099.png]

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

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

#### 测试消息大小 ####

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

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

![在这里插入图片描述][7ff7f56061664bae91a731b94dc0a936.png]

![在这里插入图片描述][89887e1c2c8243c387b9c7ca8e9a03f9.png]

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

#### 更多定制化属性配置 ####

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

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

[480fd222d29a43d5a48cf8b73e1d6a07.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/0729a677e68943d28b59c696f6a567f4.png
[35d95774c5bf49869cb67a6012a0f1d3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/e041cbd65df643b08a33966835927fc7.png
[6fc77a11c3ad446a82b7a5eb425ab099.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/42c43967a16a486197c7bc0dd718b9a1.png
[7ff7f56061664bae91a731b94dc0a936.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/c05019a7312643629ad26717cf8d2399.png
[89887e1c2c8243c387b9c7ca8e9a03f9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/01/7a1440f5cdd2468a80e137f245d709ec.png
[kafka_kafka]: https://szzdzhp.blog.csdn.net/article/details/119344584