HTTP入口类型Apache Flink StateFun

Question

我正在尝试使用Apache Flink statefun Docker映像快速构建概念验证。

https://hub.docker.com/r/apache/flink-statefun

我真的不想使用Kafka或Kinesis作为入口，我宁愿只使用HTTP，这样我就可以快速测试和原型。这可能吗？

我能找到的唯一入口示例是类似Kafka的：

kind: io.statefun.kafka.v1/ingress
spec:
id: com.ingress/Sentiment
address: kafka-broker:9092
consumerGroupId: sentiment-reader
topics:
- topic: sentimentegress
valueType: SentimentEvent
targets:
- sentiment

Answer 1

AFAIK，没有HTTP入口。您可能可以使用Kafka Connect HTTP连接器很容易地将其组合在一起，但这显然需要设置Kafka和Kafka连接。