kafka-topic

Manage your topic's configuration (partitions, replication factor, parameters), ACLs, quotas, users and get stats, without any effort with this library. It does not use the Kafka scripts and does not require ssh connection to the remote broker.

python ansible library kafka kafka-topic kafka-client kafka-topics consumer-groups kafka-acl kafka-quotas kafka-user

UpdatedFeb 25, 2025
Python

TechPrimers /spring-boot-kafka-producer-example

Star131

Spring Boot Kafka Producer Example

kafka-topic kafka-producer spring-kafka

UpdatedJul 29, 2022
Java

gnuhpc /Kafka-zk-restapi

Star124

Kafka Zookeeper RESTful API to perform topic/consumer group administration/metric(offset\lag\message) collection and monitor

kafka rest topic offset zookeeper consumer kafka-topic jmx lag partition restful-api kafka-manager consumer-group reassignment

UpdatedDec 14, 2022
Java

danielsobrado /CCDAK-Exam-Questions

Star112

Confluent Kafka questions to practice for CCDAK

kafka zookeeper kafka-topic kafka-consumer kafka-connect kafka-producer kafka-client certification kafka-streams kafka-connector kafka-cluster ccdak

UpdatedJan 12, 2025

perkss /clojure-kafka-examples

Star83

Clojure examples for Kafka and Kafka Streams (JAVA Interop)

java clojure kafka functional-programming kafka-topic kafka-streams testcontainers avro-kafka

UpdatedSep 21, 2024
Clojure

eugene-khyst /ksqldb-event-souring

Star80

Kafka is not for event sourcing, isn't it? Kafka alone is not an event store, but Kafka and ksqlDB together allow building full-featured event stores. This repository provides a sample of event sourced system that uses Kafka and ksqlDB as event store.

kafka cqrs event-sourcing kafka-topic eventsourcing solution-architecture ksqldb

UpdatedMay 4, 2021
Java

hifly81 /kafka-examples

Star68

Practical examples with Apache Kafka®

kafka avro kafka-topic confluent kafka-consumer kafka-producer kafka-client graalvm flink kafka-streams avro-schema kafka-installation microprofile kafka-events confluent-kafka ksql ktable kafka-consumers kafka-producers avroserializer

UpdatedMar 4, 2025
Java

ansrivas /spark-structured-streaming

Sponsor

Star62

Spark structured streaming with Kafka data source and writing to Cassandra

kafka spark cassandra kafka-topic

UpdatedDec 5, 2019
Scala

QuickSign /kafka-encryption

Star53

Kafka End to End Encryption

library framework encryption kafka kafka-topic kafka-consumer kafka-producer kafka-streams encryption-tool

UpdatedSep 5, 2023
Java

rollno748 /di-kafkameter

Star38

JMeter Plugin to load test Apache Kafka topics/brokers

kafka kafka-topic kafka-producer kafka-streams kafka-plugins jmeter-plugins jmeter-kafka jmeter-kafka-plugin kafkameter

UpdatedOct 2, 2024
Java

hoangtien2k3 /shopapp-backend

Star32

Source backend for website/mobile about electro, e-commerce using Java, using multi-language (EN, VI), and today's popular technologies

java docker redis kafka spring-boot docker-compose kafka-topic kafka-consumer swagger-ui restful-api swagger-docs backend-service mysql8 flyway-migrations

UpdatedMar 16, 2025
Java

Ryan-Ray-Martin /rl-trader

Star30

This MLOps project productionizes a Deep Reinforcement Learning agent with a scalable, distributed data streaming infrastructure using Kafka and Ray. A thorough walkthrough of the code is described in this article on medium:https://ryanraymartin.medium.com/deep-reinforcement-learning-for-stock-trading-with-kafka-and-rllib-d738b9634675

kafka-topic streaming-data ksqldb-cli faust-crypto