Kafka接收器的HTTP请求源？

Question

如何将播放POST路线连接到Kafka水槽？

我找到了https://github.com/jamesward/hello-play-kafka。但是它使用随机数的滴答声源附加到Kafka接收器。1

如何使POST请求路由成为绑定到Kafka接收器的源？

编辑：POST请求正文的格式为json，内容类型为application / json。发送给kafka的消息应该是完全相同的json。该路由需要一条json消息。

Answer 1

也许我误解了您的问题，但是您可以使用REST代理将消息发送到Kafka：

curl -X POST -H "Content-Type: application/vnd.kafka.json.v2+json" \
      --data '{ "records": [ { "value": { "name": "testUser0" } }, { "value": { "name": "testUser1" } } ] }' \
      "http://localhost:8082/topics/jsontest"

参考：Confluent REST Proxy docs