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

Consider usage of the confluent kafkajs library #689

Open
demetris-manikas opened this issue Dec 26, 2024 · 2 comments
Open

Consider usage of the confluent kafkajs library #689

demetris-manikas opened this issue Dec 26, 2024 · 2 comments

Comments

@demetris-manikas
Copy link
Contributor

Hi.
Just stumbled on https://github.com/confluentinc/confluent-kafka-javascript/tags
Maybe it is about time to check out the new client as it has reached the 1.0.0 version.
1.0.0 is not exactly production ready but it should not be a while before it reaches real production ready status.

@chuck-dbos
Copy link
Collaborator

Had this basically working back in July:
https://github.com/dbos-inc/dbos-transact-ts/tree/chuck/ckafka

If you'd put it to use, we can prioritize getting it updated to the newer package, updating to our new TS API, and merging.

Are you looking to produce or consume messages, or both?

@demetris-manikas
Copy link
Contributor Author

Hi,
I am looking to both produce and receive messages.

I see there is a producer communicator implementation in chuck/ckafka which is really cool to have!.
It is certainly missing from the current implementation (maybe add it in a separate PR?).

I will certainly make use of the confluence kafka client.
I use KRaft which has already produced some hiccups to DBOS-transact.

// A temporary workaround for https://github.com/tulios/kafkajs/pull/1558 until it gets fixed

Still the main concern here is to gradually move to a library with a future instead of relying on an unmaintained one.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants