如何使用kafka rest代理删除kafka主题?

91zkwejq  于 2021-06-07  发布在  Kafka
关注(0)|答案(3)|浏览(623)

如何使用kafka rest代理删除kafka主题?我尝试了以下命令,但它返回错误消息:

curl -X DELETE XXX.XX.XXX.XX:9092/topics/test_topic

如果不可能,那么如何更新删除消息和更新主题方案?

zysjyyx4

zysjyyx41#

我确认5.5.0或更高版本支持,测试结果正常(rest代理api v3)
https://docs.confluent.io/current/kafka-rest/api.html#topic

hof1towb

hof1towb2#

使用post/topics/(string:topic\u name)rest端点发布消息时,可以更新消息的架构。如果新消息的架构与同一主题中的旧消息不向后兼容,则必须将架构注册表配置为允许发布不兼容的消息,否则将出现错误。
请参见此处的“avro请求示例”:http://docs.confluent.io/3.1.1/kafka-rest/docs/api.html#post--主题-(string-topic\u name)
请参阅如何配置架构注册表以实现向前、向后或无兼容性请参阅此处的文档:http://docs.confluent.io/3.1.1/schema-registry/docs/api.html#compatibility

uqzxnwby

uqzxnwby3#

根据文档api参考,您不能通过rest代理删除主题,我同意他们的观点,因为这样的破坏性操作不应该通过暴露在外部的接口提供。
可以使用命令行实用程序在代理运行的服务器上执行主题删除操作。请参阅如何删除apache kafka中的主题

相关问题