带有 Http 请求的 Kafka 流

Question

我想实现卡夫卡流的下一个流程

from(kafka topic) -> transform (here should be http request) -> to (kafka topic)

在 kafka 流中的转换过程中设置 http 请求是否正确，还是使用标准消费者更正确？

Answer 1

可以在transform()内执行外部请求，但不建议这样做，因为请求需要同步，从而对性能(即吞吐量(产生负面影响。

但是，如果这对您来说无关，那么执行外部请求是没有问题的。