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

简介: 简单清晰的操作界面, 让你能够非常快速的创建一个新的Topic; 除了这个基本的功能外,你还可以看到在这里能够针对每个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的动态配置管理使用和分析

目录
相关文章
|
Linux Shell 数据安全/隐私保护
Linux配置代理请求
Linux配置代理请求
402 0
|
设计模式 编译器 API
【C/C++ Pimpl模式】隐藏实现细节的高效方式 (Pimpl Idiom: An Efficient Way to Hide Implementation Details)
【C/C++ Pimpl模式】隐藏实现细节的高效方式 (Pimpl Idiom: An Efficient Way to Hide Implementation Details)
1678 1
|
Web App开发 存储 监控
|
存储 分布式计算 算法
基于 Log 的通用增量 Checkpoint
本文将从 Checkpoint 的性能优化历程出发,介绍 ChangelogStateBackend 的基本机制、应用场景和未来规划,同时介绍最新版本在 State 上的一些优化工作。
7792 2
基于 Log 的通用增量 Checkpoint
|
供应链 数据管理 数据处理
RPA技术在医疗领域的应用正日益增多
【8月更文挑战第4天】RPA技术在医疗领域的应用正日益增多
299 1
|
编解码 机器人 C++
ROS2教程07 ROS2自定义消息接口
这篇文章是关于如何在ROS2(Robot Operating System 2)中创建和使用自定义消息类型的教程,包括消息类型的定义、特点、命令行工具的使用,以及如何编写和测试自定义消息类型接口的步骤。
982 0
ROS2教程07 ROS2自定义消息接口
|
存储 缓存 运维
阿里云经济型e与通用算力型u1实例性能、适用场景及常见问题
在阿里云的众多云服务器实例类型中,经济型e和通用算力型u1实例因其高性价比和广泛的适用性而备受青睐。2024年经济型e实例2核2G3M带宽40G ESSD Entry盘99元1年,通用算力型u1实例2核4G5M带宽80G ESSD Entry盘199元1年,本文将深入解析这两种实例的性能特点、适用场景以及购买建议,以供参考。
阿里云经济型e与通用算力型u1实例性能、适用场景及常见问题
|
编译器 Linux C语言
Qt浏览器模块的几点说明
Qt浏览器模块的几点说明
|
安全 JavaScript 前端开发
深入解析crypto.getRandomValues():JavaScript中的高安全性随机数生成
深入解析crypto.getRandomValues():JavaScript中的高安全性随机数生成
959 0