evilguy/kafka-streams-rest-api repository overview

⁠Kafka Streams REST api

Kafka Streams REST api is analogue for Kafka REST proxy⁠ by Confluent. The reason for making this service is that Kafka REST is not reading all messages from topic, I tried to make different timeout configurations, but they didn't worked out so well. Kafka Streams REST api is listening for topic and loading all messages into cache and allows to query it. More info here⁠

⁠How to get started

Note: Host machine should know about docker container host, if you are facing problem with connection then update hosts file mapping:

 127.0.0.1       zookeeper
 127.0.0.1       schema-registry
 127.0.0.1       broker
 127.0.0.1       kafka-streams-rest-api

MacOS /etc/hosts Win c:\windows\system32\drivers\etc\hosts

docker-compose :

# Kafka Streams REST api
  kafka-streams-rest-api:
    image: evilguy/kafka-streams-rest-api:latest
    hostname: kafka-streams-rest-api
    container_name: kafka-streams-rest-api
    depends_on:
      - zookeeper
      - broker
      - schema-registry
    ports:
      - 9096:9096
    environment:
      RUN_ARGS: --kafka.bootstrap.servers=broker:9092 --kafka.zookeeper.connect=zookeeper:2181 --kafka.schema.registry.url=http://schema-registry:8081

⁠Source

Kafka Streams UI Sources⁠ Kafka Streams Rest Api Sources⁠