kafka-streams-consumer-offsets-to-json

Consumer offsets converter

Converts Kafka __consumer_offsets to JSON

A Kafka Streams process to convert __consumer_offsets to a JSON-readable topic

GitHub

13 stars
2 watching
3 forks
Language: Scala
last commit: about 5 years ago
Linked from 1 awesome list

kafkakafkastreams

Backlinks from these awesome lists:

Related projects:

Repository Description Stars
echojc/kafka-offset-exporter Exports Kafka topic and consumer group offsets to Prometheus metrics 27
ibmstreams/streamsx.kafka A toolkit for integrating Apache Kafka with Stream Processor SPL applications 13
morningstar/kafka-offset-monitor An application to monitor Kafka consumer progress and lag. 281
kakaopensource/kakajson A Swift library providing fast conversion between JSON and model data structures. 1,172
jcustenborder/kafka-jackson Provides a standardized way to serialize and deserialize JSON data in Apache Kafka using Jackson 7
wintoncode/winton-kafka-streams A Python implementation of Apache Kafka's Streams API for stream processing applications 313
jpzk/mockedstreams A Scala library for unit-testing Kafka Streams applications without Zookeeper and Kafka Brokers 187
nodefluent/kafka-streams A Node.js library implementing Kafka Streams functionality for stream state processing and table representation. 831
dibbhatt/kafka-spark-consumer A tool for consuming messages from Kafka topics using Spark Streaming while maintaining reliability and handling failures 635
kitura/swiftkafka An SDK for interacting with Apache Kafka using Swift 60
perfectlysoft/perfect-kafka An Express Swift wrapper of librdkafka to provide a unified interface for Apache Kafka client operations 24
sourcelaborg/kafka-webview A web-based interface for reading data from Apache Kafka topics with filtering and searching capabilities 395
nmaquet/kasper A lightweight library for processing Kafka topics with idempotent at-least-once semantics 439
snowflakedb/snowflake-kafka-connector A plugin that enables data ingestion from Kafka topics to Snowflake tables 139
azhur/kafka-serde-scala Library providing implicit typeclass converters for various serialization formats to Kafka serializers 57