Skip to content
This repository has been archived by the owner on May 9, 2023. It is now read-only.

Allow to build Consumer and Producer from Java instances #74

Merged
merged 9 commits into from
Sep 2, 2022

Conversation

guizmaii
Copy link

@guizmaii guizmaii commented Aug 20, 2022

Based on #73

@sderosiaux
Copy link
Member

general question: will we be able to continue updating from upstream if we change too many things in our fork? (they keep adding improvements & fixes, so we should port them back?)

@guizmaii
Copy link
Author

@sderosiaux

We're backporting almost everything we're changing. This will be backported too.
If you look at zio-kafka, the CDK devs has 5 PRs open there ;)

@guizmaii guizmaii force-pushed the plugins_v2 branch 2 times, most recently from 67925c6 to fb33fc7 Compare August 22, 2022 08:49

def make(settings: ConsumerSettings): RManaged[Blocking, ConsumerAccess] =
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🔴
So there isn't the old make anymore?

Copy link
Author

@guizmaii guizmaii Aug 23, 2022

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It's for internal use only. This shouldn't be used by zio-kafka users

Base automatically changed from plugins_v2 to cdk-master September 2, 2022 17:56
@guizmaii guizmaii merged commit 093e31a into cdk-master Sep 2, 2022
@guizmaii guizmaii deleted the plugins_v2_0 branch September 2, 2022 18:01
gurinderu pushed a commit that referenced this pull request Sep 2, 2022
* Clean code

* Clean code

* Add `Producer.fromJavaProducer` and `Producer.fromManagedJavaProducer` functions && Clean code

* Add `Consumer.fromJavaProducer` and `Consumer.fromManagedJavaProducer` functions && Clean code

* Add `TransactionalProducer.fromJavaProducer` and `TransactionalProducer.fromManagedJavaProducer` functions

* Maximize lazyness

* Add `Consumer.javaConsumerFromSettings` and `Producer.javaProducerFromSettings` functions

* review
gurinderu pushed a commit that referenced this pull request Sep 18, 2022
* Clean code

* Clean code

* Add `Producer.fromJavaProducer` and `Producer.fromManagedJavaProducer` functions && Clean code

* Add `Consumer.fromJavaProducer` and `Consumer.fromManagedJavaProducer` functions && Clean code

* Add `TransactionalProducer.fromJavaProducer` and `TransactionalProducer.fromManagedJavaProducer` functions

* Maximize lazyness

* Add `Consumer.javaConsumerFromSettings` and `Producer.javaProducerFromSettings` functions

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

Successfully merging this pull request may close these issues.

4 participants