Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Support Kafka API #82

Open
4 tasks
vevi opened this issue Oct 24, 2022 · 1 comment
Open
4 tasks

Support Kafka API #82

vevi opened this issue Oct 24, 2022 · 1 comment
Labels
api Change in the client API enhancement New feature or request

Comments

@vevi
Copy link
Contributor

vevi commented Oct 24, 2022

It would be nice to support existing Kafka client API to leverage the existing Kafka ecosystem.

The goal is to support protocol translation for interoperability, not as a storage format.

Protocol documentation: https://kafka.apache.org/protocol.html

Tasks:

  • A: Implement basic Kafka API operations like metadata (3), api versions (18), find coordinator (10) and create topics (19).
  • B: Implement Produce (0) operation: decode a record batch, use the key to route and call produce by message.
  • C: Implement operations related to fetching/consuming: fetch (1), list offsets (2) and offset commit (8). These requires creating an abstraction for the request writer (currently HTTP only).
  • D: Support compression
@vevi vevi added enhancement New feature or request api Change in the client API labels Oct 24, 2022
@jorgebay
Copy link
Contributor

jorgebay commented Nov 29, 2022

I've created a working branch (82-kafka-api) to understand the complexity of this feature.

I've added some info on this ticket about what needs to be done to support the Kafka API for producing and consuming.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
api Change in the client API enhancement New feature or request
Projects
None yet
Development

No branches or pull requests

2 participants