当前位置: 首页 > 科技观察

了解Streaming如何快速优雅创建Topic

时间:2023-03-14 08:40:23 科技观察

操作流程操作亮点配置清理策略测试消息大小更多自定义属性配置操作流程①,点击添加话题②,填写话题基本信息和配置③,点击确认,创建成功!操作亮点简洁明了的操作界面,让您快速创建新的Topic;除了这个基础功能,你还可以看到这里可以为每个Topic做更细粒度的自定义配置。配置清理策略普通topic默认清理策略为delete,__consumer_offset默认清理策略为compactdelete:消息过期直接删除compact:消息压缩,如果消息key相同,则value的值是最近的一个。比如__consumer_offset就是记录消费者组消费的offset的信息。当同一个消费者组消费一个TopicPartition时,偏移消息会被写入到Topic中。每次写的Key都是一样的,但是Value是不一样的。在获取当前消费者组消费的Offset信息时,读取??最新的key。而如果消息过期被清理,那么之前的消息也会被删除。测试消息大小想设置该主题的指定大小,但不知道消息的大概大小?没关系,知流给你提供了一个计算窗口。在这里插入图片描述,让你的消息体负责,它会自动显示占用的字节数,让你在配置参数属性时有依据。更多自定义属性配置以下配置仅对主题有效,此处配置的属性均为动态配置。什么是动态配置可以阅读:【kafka】Kafka的动态配置管理使用与分析可以点击阅读原文直接访问KnowStreaming体验环境https://demo.knowstreaming.com/