go - 有没有更好的方法来编辑带有消息过期时间间隔的kafka主题?

标签 go apache-kafka

使用现有的golang库saram,有没有办法创建具有特定到期时间(用于消息)的主题?

之后,我们可以编辑它,而无需删除和重新创建主题。

最佳答案

ClusterAdmin 客户端可以创建包含 TopicDetail 的主题,这些主题包含配置条目的映射,您可以设置其保留期限

您以后可以使用 AlterConfigsRequest 对其进行编辑

关于go - 有没有更好的方法来编辑带有消息过期时间间隔的kafka主题?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/59334146/

相关文章:

map[Task]int64 其中 Task 是一个接口(interface)

go - 如何解码毒蛇配置以使用破折号字符进行结构化

java - 卡夫卡流 : Should we advance stream time per key to test Windowed suppression?

java - Kafka Connect 实现错误

golang如何将C代码中的 panic 重定向到文件

html - 在 Golang 的 HTML 模板中使用 Vue.js

go - http.Hijacker 的返回值是什么?

sql-server - 重置 JDBC Kafka 连接器以从头开始提取行?

apache-kafka - 如何使用 kafka.tools.JmxTool 访问 JMX 指标?

java - 来自 kafka 消费者的 InstanceAlreadyExistsException