如何使用 Kafka REST 代理删除 Kafka 主题?
How to delete Kafka topic using Kafka REST Proxy?
如何使用Kafka REST Proxy删除Kafka主题?我尝试了以下命令,但它 returns 错误消息:
curl -X DELETE XXX.XX.XXX.XX:9092/topics/test_topic
如果不能,那如何更新删除消息和更新主题的方案?
根据文档API Reference,您不能通过REST Proxy删除主题,我同意他们的看法,因为这样的破坏性操作不应该通过暴露在外的接口进行。
可以使用命令行实用程序在代理运行的服务器上执行主题删除操作。参见
您可以在使用 POST /topics/(string: topic_name) REST 端点发布消息时更新消息的架构。如果新消息的架构与同一主题中的旧消息不向后兼容,您将必须配置架构注册表以允许发布不兼容的消息,否则您将收到错误消息。
请在此处查看 "Example Avro request":
http://docs.confluent.io/3.1.1/kafka-rest/docs/api.html#post--topics-(string-topic_name)
了解如何配置架构注册表以实现向前、向后或不兼容,请参阅此处的文档:
http://docs.confluent.io/3.1.1/schema-registry/docs/api.html#compatibility
确认5.5.0以上版本支持,测试正常。 (REST 代理 API v3)
如何使用Kafka REST Proxy删除Kafka主题?我尝试了以下命令,但它 returns 错误消息:
curl -X DELETE XXX.XX.XXX.XX:9092/topics/test_topic
如果不能,那如何更新删除消息和更新主题的方案?
根据文档API Reference,您不能通过REST Proxy删除主题,我同意他们的看法,因为这样的破坏性操作不应该通过暴露在外的接口进行。
可以使用命令行实用程序在代理运行的服务器上执行主题删除操作。参见
您可以在使用 POST /topics/(string: topic_name) REST 端点发布消息时更新消息的架构。如果新消息的架构与同一主题中的旧消息不向后兼容,您将必须配置架构注册表以允许发布不兼容的消息,否则您将收到错误消息。
请在此处查看 "Example Avro request": http://docs.confluent.io/3.1.1/kafka-rest/docs/api.html#post--topics-(string-topic_name)
了解如何配置架构注册表以实现向前、向后或不兼容,请参阅此处的文档: http://docs.confluent.io/3.1.1/schema-registry/docs/api.html#compatibility
确认5.5.0以上版本支持,测试正常。 (REST 代理 API v3)