You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Benoit Maggi | AT Internet <be...@atinternet.com> on 2018/11/29 10:52:08 UTC

Will KafkaFuture becomes CompletableFuture ?

Hi everyone,

I have a use case, where a KafkaCompletableFuture would be useful.

As  far as I can tell KafkaFuture only implements Future < public abstract class KafkaFuture<T> implements Future<T> > [1]
I found this KIP suggesting the change to CompletableFuture < When KIP-118<https://cwiki.apache.org/confluence/display/KAFKA/KIP-118%3A+Drop+Support+for+Java+7> is implemented, KafkaFuture can extend CompletableFuture or implement CompletionStage. > [2]

KIP-218 is resolved in 1.1.0 [3]
KIP-118 is resolved in 2.0.0 [4]

Is the change to CompletableFuture  still planned ?
Is there a KIP or a JIRA ticket to keep track on this ongoing task ? (I didn't found one)

Regards,
Benoit

1 : https://github.com/apache/kafka/blob/3cdc78e6bb1f83973a14ce1550fe3874f7348b05/clients/src/main/java/org/apache/kafka/common/KafkaFuture.java
2 :  https://cwiki.apache.org/confluence/display/KAFKA/KIP-218%3A+Make+KafkaFuture.Function+java+8+lambda+compatible
3 : https://issues.apache.org/jira/browse/KAFKA-6018
4 :  https://issues.apache.org/jira/browse/KAFKA-4423



Re: Will KafkaFuture becomes CompletableFuture ?

Posted by Sönke Liebau <so...@opencore.com.INVALID>.
That might be the case, yes.

I've fixed the title, maybe that saves the next poor soul some trouble :)

On Thu, Nov 29, 2018 at 2:12 PM Benoit Maggi | AT Internet <
benoit.maggi@atinternet.com> wrote:

> Hi Sönke,
>
> Many thanks, that was exactly what I was looking for 😊
>
> I didn't found this issue (probably due to the typo in the title)
>
> Best Regards,
> Benoit
>
> -----Message d'origine-----
> De : Sönke Liebau <so...@opencore.com.INVALID>
> Envoyé : jeudi 29 novembre 2018 13:02
> À : users@kafka.apache.org
> Objet : Re: Will KafkaFuture becomes CompletableFuture ?
>
> Hi Benoit,
>
> have you looked at KAFKA-6987
> <https://issues.apache.org/jira/browse/KAFKA-6987>? That seems to me to
> be the one that had the most recent activity around this.
> You probably found this as well but it wasn't mentioned in your mail, so I
> thought I'd point it out.
>
> Best regards,
> Sönke
>
> On Thu, Nov 29, 2018 at 12:08 PM Benoit Maggi | AT Internet <
> benoit.maggi@atinternet.com> wrote:
>
> > Hi everyone,
> >
> > I have a use case, where a KafkaCompletableFuture would be useful.
> >
> > As  far as I can tell KafkaFuture only implements Future < public
> > abstract class KafkaFuture<T> implements Future<T> > [1] I found this
> > KIP suggesting the change to CompletableFuture < When KIP-118<
> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-118%3A+Drop+Supp
> > ort+for+Java+7> is implemented, KafkaFuture can extend
> > CompletableFuture or implement CompletionStage. > [2]
> >
> > KIP-218 is resolved in 1.1.0 [3]
> > KIP-118 is resolved in 2.0.0 [4]
> >
> > Is the change to CompletableFuture  still planned ?
> > Is there a KIP or a JIRA ticket to keep track on this ongoing task ?
> > (I didn't found one)
> >
> > Regards,
> > Benoit
> >
> > 1 :
> > https://github.com/apache/kafka/blob/3cdc78e6bb1f83973a14ce1550fe3874f
> > 7348b05/clients/src/main/java/org/apache/kafka/common/KafkaFuture.java
> > 2 :
> > https://cwiki.apache.org/confluence/display/KAFKA/KIP-218%3A+Make+Kafk
> > aFuture.Function+java+8+lambda+compatible
> > 3 : https://issues.apache.org/jira/browse/KAFKA-6018
> > 4 :  https://issues.apache.org/jira/browse/KAFKA-4423
> >
> >
> >
>
> --
> Sönke Liebau
> Partner
> Tel. +49 179 7940878
> OpenCore GmbH & Co. KG - Thomas-Mann-Straße 8 - 22880 Wedel - Germany
>


-- 
Sönke Liebau
Partner
Tel. +49 179 7940878
OpenCore GmbH & Co. KG - Thomas-Mann-Straße 8 - 22880 Wedel - Germany

RE: Will KafkaFuture becomes CompletableFuture ?

Posted by Benoit Maggi | AT Internet <be...@atinternet.com>.
Hi Sönke,

Many thanks, that was exactly what I was looking for 😊

I didn't found this issue (probably due to the typo in the title) 

Best Regards,
Benoit

-----Message d'origine-----
De : Sönke Liebau <so...@opencore.com.INVALID> 
Envoyé : jeudi 29 novembre 2018 13:02
À : users@kafka.apache.org
Objet : Re: Will KafkaFuture becomes CompletableFuture ?

Hi Benoit,

have you looked at KAFKA-6987
<https://issues.apache.org/jira/browse/KAFKA-6987>? That seems to me to be the one that had the most recent activity around this.
You probably found this as well but it wasn't mentioned in your mail, so I thought I'd point it out.

Best regards,
Sönke

On Thu, Nov 29, 2018 at 12:08 PM Benoit Maggi | AT Internet < benoit.maggi@atinternet.com> wrote:

> Hi everyone,
>
> I have a use case, where a KafkaCompletableFuture would be useful.
>
> As  far as I can tell KafkaFuture only implements Future < public 
> abstract class KafkaFuture<T> implements Future<T> > [1] I found this 
> KIP suggesting the change to CompletableFuture < When KIP-118< 
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-118%3A+Drop+Supp
> ort+for+Java+7> is implemented, KafkaFuture can extend 
> CompletableFuture or implement CompletionStage. > [2]
>
> KIP-218 is resolved in 1.1.0 [3]
> KIP-118 is resolved in 2.0.0 [4]
>
> Is the change to CompletableFuture  still planned ?
> Is there a KIP or a JIRA ticket to keep track on this ongoing task ? 
> (I didn't found one)
>
> Regards,
> Benoit
>
> 1 :
> https://github.com/apache/kafka/blob/3cdc78e6bb1f83973a14ce1550fe3874f
> 7348b05/clients/src/main/java/org/apache/kafka/common/KafkaFuture.java
> 2 :
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-218%3A+Make+Kafk
> aFuture.Function+java+8+lambda+compatible
> 3 : https://issues.apache.org/jira/browse/KAFKA-6018
> 4 :  https://issues.apache.org/jira/browse/KAFKA-4423
>
>
>

--
Sönke Liebau
Partner
Tel. +49 179 7940878
OpenCore GmbH & Co. KG - Thomas-Mann-Straße 8 - 22880 Wedel - Germany

Re: Will KafkaFuture becomes CompletableFuture ?

Posted by Sönke Liebau <so...@opencore.com.INVALID>.
Hi Benoit,

have you looked at KAFKA-6987
<https://issues.apache.org/jira/browse/KAFKA-6987>? That seems to me to be
the one that had the most recent activity around this.
You probably found this as well but it wasn't mentioned in your mail, so I
thought I'd point it out.

Best regards,
Sönke

On Thu, Nov 29, 2018 at 12:08 PM Benoit Maggi | AT Internet <
benoit.maggi@atinternet.com> wrote:

> Hi everyone,
>
> I have a use case, where a KafkaCompletableFuture would be useful.
>
> As  far as I can tell KafkaFuture only implements Future < public abstract
> class KafkaFuture<T> implements Future<T> > [1]
> I found this KIP suggesting the change to CompletableFuture < When KIP-118<
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-118%3A+Drop+Support+for+Java+7>
> is implemented, KafkaFuture can extend CompletableFuture or implement
> CompletionStage. > [2]
>
> KIP-218 is resolved in 1.1.0 [3]
> KIP-118 is resolved in 2.0.0 [4]
>
> Is the change to CompletableFuture  still planned ?
> Is there a KIP or a JIRA ticket to keep track on this ongoing task ? (I
> didn't found one)
>
> Regards,
> Benoit
>
> 1 :
> https://github.com/apache/kafka/blob/3cdc78e6bb1f83973a14ce1550fe3874f7348b05/clients/src/main/java/org/apache/kafka/common/KafkaFuture.java
> 2 :
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-218%3A+Make+KafkaFuture.Function+java+8+lambda+compatible
> 3 : https://issues.apache.org/jira/browse/KAFKA-6018
> 4 :  https://issues.apache.org/jira/browse/KAFKA-4423
>
>
>

-- 
Sönke Liebau
Partner
Tel. +49 179 7940878
OpenCore GmbH & Co. KG - Thomas-Mann-Straße 8 - 22880 Wedel - Germany