You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Debraj Manna <su...@gmail.com> on 2017/11/22 14:52:03 UTC
Fwd: Running apache samza with Kafka Client 1.0 - JIRA - SAMZA - 1418
Hi
I posted the same query in samza mailing list. But I did not get any reply.
Anyone has any thoughts?
Sent from GMail on Android
---------- Forwarded message ----------
From: "Debraj Manna" <su...@gmail.com>
Date: Nov 21, 2017 5:34 PM
Subject: Running apache samza with Kafka Client 1.0 - JIRA - SAMZA - 1418
To: <de...@samza.apache.org>
Cc:
Hi
I am facing the same below issue when trying to use kafka client 1.0 with
samza
https://issues.apache.org/jira/browse/SAMZA-1418
I could not find any related ticket with a fix.
How are we supposed to run apache samza with the latest Kafka Client 1.0?
It looks like I have to use kafka-clients-0.11.0.0.jar .
*Versions*
Kafka Broker / Cluster - 1.0
samza-api-0.13.0.jar
samza-core_2.11-0.13.0.jar
samza-kafka_2.11-0.13.0.jar
samza-kv_2.11-0.13.0.jar
samza-yarn_2.11-0.13.0.jar
Re: Running apache samza with Kafka Client 1.0 - JIRA - SAMZA - 1418
Posted by Ismael Juma <is...@juma.me.uk>.
Yes. Since the Scala clients have not changed much, there isn't much
benefit in upgrading anyway.
Ismael
On Wed, Nov 22, 2017 at 3:59 PM, Debraj Manna <su...@gmail.com>
wrote:
> Ok so until the issue is resolved by samza I have to stick with kafka
> client 0.11 ?
>
> On Wed, Nov 22, 2017 at 9:11 PM, Ismael Juma <is...@juma.me.uk> wrote:
>
> > Hi Debraj,
> >
> > It looks like Samza is relying on an internal class. My understanding is
> > that kafka.javaapi.TopicMetadata is the public version. Either way, all
> > these classes are used by the deprecated Scala consumers and will be
> > removed in a future version. It would be great if Samza migrated to the
> > Java consumer.
> >
> > Ismael
> >
> > On Wed, Nov 22, 2017 at 2:52 PM, Debraj Manna <su...@gmail.com>
> > wrote:
> >
> > > Hi
> > >
> > > I posted the same query in samza mailing list. But I did not get any
> > reply.
> > >
> > > Anyone has any thoughts?
> > >
> > > Sent from GMail on Android
> > > ---------- Forwarded message ----------
> > > From: "Debraj Manna" <su...@gmail.com>
> > > Date: Nov 21, 2017 5:34 PM
> > > Subject: Running apache samza with Kafka Client 1.0 - JIRA - SAMZA -
> 1418
> > > To: <de...@samza.apache.org>
> > > Cc:
> > >
> > > Hi
> > >
> > >
> > > I am facing the same below issue when trying to use kafka client 1.0
> with
> > > samza
> > >
> > > https://issues.apache.org/jira/browse/SAMZA-1418
> > >
> > > I could not find any related ticket with a fix.
> > >
> > > How are we supposed to run apache samza with the latest Kafka Client
> 1.0?
> > > It looks like I have to use kafka-clients-0.11.0.0.jar .
> > >
> > > *Versions*
> > > Kafka Broker / Cluster - 1.0
> > > samza-api-0.13.0.jar
> > > samza-core_2.11-0.13.0.jar
> > > samza-kafka_2.11-0.13.0.jar
> > > samza-kv_2.11-0.13.0.jar
> > > samza-yarn_2.11-0.13.0.jar
> > >
> >
>
Re: Running apache samza with Kafka Client 1.0 - JIRA - SAMZA - 1418
Posted by Debraj Manna <su...@gmail.com>.
Ok so until the issue is resolved by samza I have to stick with kafka
client 0.11 ?
On Wed, Nov 22, 2017 at 9:11 PM, Ismael Juma <is...@juma.me.uk> wrote:
> Hi Debraj,
>
> It looks like Samza is relying on an internal class. My understanding is
> that kafka.javaapi.TopicMetadata is the public version. Either way, all
> these classes are used by the deprecated Scala consumers and will be
> removed in a future version. It would be great if Samza migrated to the
> Java consumer.
>
> Ismael
>
> On Wed, Nov 22, 2017 at 2:52 PM, Debraj Manna <su...@gmail.com>
> wrote:
>
> > Hi
> >
> > I posted the same query in samza mailing list. But I did not get any
> reply.
> >
> > Anyone has any thoughts?
> >
> > Sent from GMail on Android
> > ---------- Forwarded message ----------
> > From: "Debraj Manna" <su...@gmail.com>
> > Date: Nov 21, 2017 5:34 PM
> > Subject: Running apache samza with Kafka Client 1.0 - JIRA - SAMZA - 1418
> > To: <de...@samza.apache.org>
> > Cc:
> >
> > Hi
> >
> >
> > I am facing the same below issue when trying to use kafka client 1.0 with
> > samza
> >
> > https://issues.apache.org/jira/browse/SAMZA-1418
> >
> > I could not find any related ticket with a fix.
> >
> > How are we supposed to run apache samza with the latest Kafka Client 1.0?
> > It looks like I have to use kafka-clients-0.11.0.0.jar .
> >
> > *Versions*
> > Kafka Broker / Cluster - 1.0
> > samza-api-0.13.0.jar
> > samza-core_2.11-0.13.0.jar
> > samza-kafka_2.11-0.13.0.jar
> > samza-kv_2.11-0.13.0.jar
> > samza-yarn_2.11-0.13.0.jar
> >
>
Re: Running apache samza with Kafka Client 1.0 - JIRA - SAMZA - 1418
Posted by Ismael Juma <is...@juma.me.uk>.
Hi Debraj,
It looks like Samza is relying on an internal class. My understanding is
that kafka.javaapi.TopicMetadata is the public version. Either way, all
these classes are used by the deprecated Scala consumers and will be
removed in a future version. It would be great if Samza migrated to the
Java consumer.
Ismael
On Wed, Nov 22, 2017 at 2:52 PM, Debraj Manna <su...@gmail.com>
wrote:
> Hi
>
> I posted the same query in samza mailing list. But I did not get any reply.
>
> Anyone has any thoughts?
>
> Sent from GMail on Android
> ---------- Forwarded message ----------
> From: "Debraj Manna" <su...@gmail.com>
> Date: Nov 21, 2017 5:34 PM
> Subject: Running apache samza with Kafka Client 1.0 - JIRA - SAMZA - 1418
> To: <de...@samza.apache.org>
> Cc:
>
> Hi
>
>
> I am facing the same below issue when trying to use kafka client 1.0 with
> samza
>
> https://issues.apache.org/jira/browse/SAMZA-1418
>
> I could not find any related ticket with a fix.
>
> How are we supposed to run apache samza with the latest Kafka Client 1.0?
> It looks like I have to use kafka-clients-0.11.0.0.jar .
>
> *Versions*
> Kafka Broker / Cluster - 1.0
> samza-api-0.13.0.jar
> samza-core_2.11-0.13.0.jar
> samza-kafka_2.11-0.13.0.jar
> samza-kv_2.11-0.13.0.jar
> samza-yarn_2.11-0.13.0.jar
>