This version is still in development and is not considered stable yet. For the latest stable version, please use Korvet 0.19!

Kafka API

Korvet implements the Kafka protocol, allowing you to use existing Kafka clients and tools.

Supported Operations

  • Produce: Send messages to topics

  • Fetch: Read messages from topics

  • Consumer Groups: Coordinate multiple consumers with offset tracking

  • Topic Management: Create and list topics

Client Compatibility

Korvet is compatible with standard Kafka clients:

  • Java: kafka-clients library

  • Python: kafka-python, confluent-kafka-python

  • Go: sarama, confluent-kafka-go

  • Node.js: kafkajs, node-rdkafka

  • Command-line: kafka-console-producer, kafka-console-consumer

  • Databricks: Spark Structured Streaming (see Databricks Integration)

  • Apache Flink: KafkaSource and KafkaSink (see Apache Flink Integration)

  • Kafka Connect: distributed and standalone workers with the existing connector ecosystem (see Kafka Connect Integration)

Connection

Connect to Korvet using the standard Kafka bootstrap server configuration:

bootstrap.servers=localhost:9092

Next Steps