Popular repositories Loading

1. KCM KCM Public

   Intuitive UI for Kafka Connect, Topics, ACLs, Schema Registry, etc.

   Shell 4

2. kcm-kafka-connect-adls-sink kcm-kafka-connect-adls-sink Public

   Kafka Connect Sink for ADLS Gen2 with SAS auth, Avro support, GZIP compression, and partition-based file batching.

   Java 3

3. kafka-streams kafka-streams Public

   Reusable Kafka Streams + Spring Boot 3 starter (Java 21) with sample topology, metrics, and env-based configuration for cloud/container deployments.

   Java 2

4. kafka-to-adls-springboot-example kafka-to-adls-springboot-example Public

   Spring Boot application that consumes Kafka messages in batches and writes them to Azure Data Lake Storage Gen2 using SAS authentication, generating one ADLS file per poll.

   Java

5. kafka-streams-exception-handler kafka-streams-exception-handler Public

6. kcm-connect-guardian kcm-connect-guardian Public

   KCM Connect Guardian monitors Kafka Connect connectors and tasks, detects FAILED states, and automatically restarts them to improve reliability.

   Shell