Re: Setting topic's offset from the shell

You might want to set group.id config in kafka-console-consumer (or in any other consumer) to the value which you haven't used before. This will replay all available messages in the topic from start if you use --from-beginning in console consumer. On Wed, 28 Feb 2018 at 14:19 Zoran

Re: [ANNOUNCE] New Kafka PMC Member: Rajini Sivaram

Congratulations Rajini ! On Fri, 19 Jan 2018 at 07:11 Jun Rao wrote: > Congratulations, Rajini ! > > Jun > > On Wed, Jan 17, 2018 at 10:48 AM, Gwen Shapira wrote: > > > Dear Kafka Developers, Users and Fans, > > > > Rajini Sivaram became a committer in

Re: [DISCUSS] KIP-174 - Deprecate and remove internal converter configs in WorkerConfig

this and get the deprecation commit through. It seems like > a good idea as this has been confusing to users from day one. > > -Ewen > > On Wed, Aug 9, 2017 at 5:18 AM, UMESH CHAUDHARY <umesh9...@gmail.com> > wrote: > >> Thanks Ewen, >> I just edited the

Re: Kafka isync replica

Do you find any messages on broker 3 w.r.t. Topic: XYZ Partition 82? Also broker 3 is in isr for other partitions (at least 83,84) so I don't see any broker issue in this. On Thu, 14 Dec 2017 at 01:23 Tarun Garg wrote: > Hi, > > I have a Kafka cluster and it is running from

Re: [ANNOUNCE] New committer: Onur Karaman

Congratulations Onur! On Tue, 7 Nov 2017 at 21:44 Jun Rao wrote: > Affan, > > All known problems in the controller are described in the doc linked from > https://issues.apache.org/jira/browse/KAFKA-5027. > > Thanks, > > Jun > > On Mon, Nov 6, 2017 at 11:00 PM, Affan Syed

Re: [ANNOUNCE] Apache Kafka 1.0.0 Released

> > Karau, Hooman Broujerdi, Hugo Louro, Ismael Juma, Jacek Laskowski, Jakub > > Scholz, James Cheng, James Chien, Jan Burkhardt, Jason Gustafson, Jeff > > Chao, Jeff Klukas, Jeff Widman, Jeremy Custenborder, Jeyhun Karimov, > > Jiangjie Qin, Joel Dice, Joel Hamill, Jo

Re: [DISCUSS] KIP-174 - Deprecate and remove internal converter configs in WorkerConfig

nfig is specified" > and "since the JsonConverter is the default, the configs will be removed > immediately from the example worker configuration files"). > > Other than that this LGTM and I'll be happy to get rid of those settings! > > -Ewen > > On Tue, Aug

Re: [DISCUSS] KIP-174 - Deprecate and remove internal converter configs in WorkerConfig

Hi Ewen, Sorry, I am bit late in responding this. Thanks for your inputs and I've updated the KIP by adding more details to it. Regards, Umesh On Mon, 31 Jul 2017 at 21:51 Ewen Cheslack-Postava <e...@confluent.io> wrote: > On Sun, Jul 30, 2017 at 10:21 PM, UMESH CHAUDHARY <umesh9.

Re: [DISCUSS] KIP-174 - Deprecate and remove internal converter configs in WorkerConfig

o newer versions which would no longer support that? > > -Ewen > > > On Fri, Jul 14, 2017 at 2:37 AM, UMESH CHAUDHARY <umesh9...@gmail.com> > wrote: > > > Hi there, > > Resending as probably missed earlier to grab your attention. > > > > Reg

[DISCUSS] KIP-174 - Deprecate and remove internal converter configs in WorkerConfig

Hi there, Resending as probably missed earlier to grab your attention. Regards, Umesh -- Forwarded message - From: UMESH CHAUDHARY <umesh9...@gmail.com> Date: Mon, 3 Jul 2017 at 11:04 Subject: [DISCUSS] KIP-174 - Deprecate and remove internal converter configs in Worker

Re: Apache Kafka integration using Apache Camel

Did you test that kafka console consumer is displaying the produced message? On Fri, Jan 6, 2017 at 9:18 AM, Gupta, Swati wrote: > Hello All, > > > > I am trying to create a Consumer using Apache Camel for a topic in Apache > Kafka. > I am using Camel 2.17.0 and Kafka 0.10

Re: which port should I use 9091 or 9092 or 2181 to send messages through kafka when using a client Library?

No that is not required, when you use new consumer API. You have to specify bootstrap.servers, which will have 9092 (for PLAINTEXT usually ). In old consumer API you need zookeeper server which points on 2181. On Thu, 15 Sep 2016 at 17:03 kant kodali wrote: > I haven't

Re: Question regarding functionality of MirrorMaker

is hang MM was not able to replicate other topics. When I deleted that zombie topic, MM worked as expected. Regards, Umesh Chaudhary On Fri, 26 Aug 2016 at 12:40 cs user <acldstk...@gmail.com> wrote: > Hi Umesh, > > I haven't had that problem, it seems to work fine for me. The on

Re: Question regarding functionality of MirrorMaker

at the time of its startup and mirrors the data. When you add some new topics after its startup it doesn't pick it automatically? Regards, Umesh Chaudhary On Thu, 25 Aug 2016 at 19:23 cs user <acldstk...@gmail.com> wrote: > Hi Umesh, > > I am new to kafka as well, and configuring the Mir

Question regarding functionality of MirrorMaker

Hey Folks, I was trying to understand the behavior of MirrorMaker but looks like I am missing something here. Please see the steps which I performed : 1) I configured MM on source Kafka cluster 2) Created a topic and pushed some data in it using console producer. 3) My understanding is that MM

List all Kafka consumers

Hi Folks, Was searching for some command to list all connected(live) producers to Kafka brokers. Is there any such tool to get the live producers and consumers? Regards, Umesh