如何清除消息集线器主题？

Question

在使用MessageHub进行开发时，我经常会发现我想从一个主题中清除我的开发数据。

如何清除MessageHub主题？

Answer 1

从Message Hub中清除Kafka主题的唯一方法是删除并重新创建该主题。您可以使用Message Hub服务提供的Web UI手动执行此操作。或者，您可以使用REST API来管理Kafka主题。使用REST API的优点是可以编写脚本。

Message Hub REST API在Swagger中的文档如下：https://github.com/ibm-messaging/message-hub-docs/blob/master/kafka-administration-api/kafkatopicmanagement.yaml。如果你不是一个大摇大摆的大师，那么剩下要删除的调用是：

POST /admin/topics/<TOPICNAME>

您需要使用x-auth-token头指定消息集线器API密钥（来自VCAP_SERVICES)，以验证请求。因此curl实现示例如下所示：

curl -k -v -X DELETE -H 'Content-Type: application/json' -H 'Accept: */*' \
    -H 'X-Auth-Token: yourapikeyhere' \                                          
    https://admin-endpoint-goes-here/admin/topics/<TOPICNAME>

Kafaka主题删除是异步的。因此，在重新创建主题之前，您需要确保原始主题的删除过程已经完成。这可以通过轮询以下endpoint直到它返回404（未找到）状态代码来实现：

GET /topics/<TOPICNAME>

（x-auth-token头必须同样存在）。卷曲：

curl -k -v -H -H 'Accept: application/json' \
    -H 'X-Auth-Token: yourapikeyhere' \
    https://admin-endpoint-goes-here/topics/<TOPICNAME>

要（重新）创建主题，需要以下REST请求（还需要x-auth-token):

POST /admin/topics

{                                                                                
  "name": "TOPICNAME",                                                        
  "partitions": 2                                                                
}

在curl中，这将是：

curl -k -v -H 'Content-Type: application/json' -H 'Accept: */*' \
    -H 'X-Auth-Token: yourapikeyhere' \
    -d '{ "name": "TOPICNAME", "partitions": 2 }' \
    https://admin-endpoint-goes-here/admin/topics