I am trying to quickly put together a proof of concept using the Apache Flink statefun Docker image.
https://hub.docker.com/r/apache/flink-statefun
I don't really want to use Kafka or Kinesis as an ingress, I'd rather just use HTTP so I can quickly test and prototype. Is this possible?
The only ingress examples I can find are for Kafka like:
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
AFAIK, there's no HTTP ingress. You could probably put one together fairly easily using the Kafka Connect HTTP connector, but that would obviously involve setting up Kafka and Kafka Connect.