kafka-spark-consumer

ibmstreams/streamsx.kafka13

Kafka integrator

A toolkit for integrating Apache Kafka with Stream Processor SPL applications

streamthoughts/kafka-connect-file-pulse324

File processor

A tool that enables streaming and processing of various file formats into Apache Kafka

yannael/kafka-sparkstreaming-cassandra97

Streaming environment

An environment for experimenting with real-time data processing using Kafka, Spark streaming, and Cassandra

instaclustr/sample-kafkasparkcassandra23

Spark Data Processor

An introductory Scala app using Apache Spark Streaming to process data from Kafka and write summaries to Cassandra.

sderosiaux/kafka-streams-consumer-offsets-to-json13

Consumer offsets converter

Converts Kafka __consumer_offsets to JSON

b/kafka-websocket347

Kafka client

Provides a WebSocket interface to interact with Kafka's distributed message broker

streamthoughts/azkarra-streams185

Kafka Streams tool

A lightweight Java framework to develop and manage cloud-native streaming microservices based on Apache Kafka Streams.

snowflakedb/snowflake-kafka-connector141

Data pipeline

A plugin that enables data ingestion from Kafka topics to Snowflake tables

fgeller/kt947

Kafka client

A command-line tool for interacting with Apache Kafka clusters

turbolytics/sql-flow73

Kafka consumer

An open-source tool that enables writing Kafka stream processing logic using standard SQL syntax.

raystack/firehose329

Data pipeline service

Delivers real-time streaming data to various destinations

dart-kafka/kafka56

Kafka client library

Provides a Dart client library for interacting with the Apache Kafka message broker

mre/kafka-influxdb216

Metric buffer

A Kafka consumer for InfluxDB that buffers metric data during high loads and enables reliable sending of metrics from remote locations.

nodefluent/kafka-streams831

Stream processor

A Node.js library implementing Kafka Streams functionality for stream state processing and table representation.

perfectlysoft/perfect-kafka24

Kafka Client Wrapper

An Express Swift wrapper of librdkafka to provide a unified interface for Apache Kafka client operations