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

Connection

Connect to Korvet using the standard Kafka bootstrap server configuration:

bootstrap.servers=localhost:9092