我遵循合流的kafka文档来使用rest代理。
https://docs.confluent.io/current/kafka-rest/docs/intro.html
在“生成和使用json消息”部分中，我使用了以下api

I.)
POST : "http://localhost:8082/topics/jsontest"
Header : "Content-Type: application/vnd.kafka.json.v2+json"
"Accept: application/vnd.kafka.v2+json"
JSON BODY : {"records":[{"value":{"foo":"bar"}}]}

II.)
POST : "http://localhost:8082/consumers/my_json_consumer"
Header : "Content-Type: application/vnd.kafka.json.v2+json"
JSON BODY : {"name": "my_consumer_instance", "format": "json", "auto.offset.reset": "earliest"}

III.)
POST : "http://localhost:8082/consumers/my_json_consumer/instances/my_consumer_instance/subscription"
Header : "Content-Type: application/vnd.kafka.v2+json"
JSON BODY : {"topics":["jsontest"]}

IV.) 
GET : "http://localhost:8082/consumers/my_json_consumer/instances/my_consumer_instance/records"
Accept : "application/vnd.kafka.json.v2+json"

我能够成功地执行上述api。
我的问题是，每当我想测试这个功能时，我都需要创建新的示例（例如：my\u consumer\u示例）。所以，我不能在不改变任何代码的情况下实时测试这个。我无法测试发送数据的流。
这样行吗？如何避免每次创建新示例（或者）是否有其他方法需要处理此部分？
如果有人知道，请分享你的想法来解决这个问题。