Search code examples
apache-flinkflink-statefun

HTTP ingress type Apache Flink StateFun

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
Solution

  • 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.