Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Andras Beni
Congratulations, Manikumar! Srinivas Reddy ezt írta (időpont: 2018. okt. 12., P 3:00): > Congratulations Mani. We'll deserved  > > - > Srinivas > > - Typed on tiny keys. pls ignore typos.{mobile app} > > On Fri 12 Oct, 2018, 01:39 Jason Gustafson, wrote: > > > Hi all, > > > > The PMC for

Re: How to manipulate client settings through AdminAPI?

2018-10-11 Thread SJTU胡昊坤
Hi Will, Unfortunately, you can't use AdminClient to do that. Because Kafka use zookeeper to keep the user quotas. And there is no API for this. You can implement this feature by writing raw data to zookeeper. The protocol is simple: first, write data to: znode:

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Srinivas Reddy
Congratulations Mani. We'll deserved  - Srinivas - Typed on tiny keys. pls ignore typos.{mobile app} On Fri 12 Oct, 2018, 01:39 Jason Gustafson, wrote: > Hi all, > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we > are > pleased to announce that he has accepted! >

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Matthias J. Sax
Congrats! On 10/11/18 2:31 PM, Yishun Guan wrote: > Congrats Manikumar! > On Thu, Oct 11, 2018 at 1:20 PM Sönke Liebau > wrote: >> >> Great news, congratulations Manikumar!! >> >> On Thu, Oct 11, 2018 at 9:08 PM Vahid Hashemian >> wrote: >> >>> Congrats Manikumar! >>> >>> On Thu, Oct 11, 2018

Inconsistent Replica list for a partition

2018-10-11 Thread Koushik Chitta
Hi, The no. of replicas of partition : 1 is less than rest of the partitions, In which scenarios this can happen ? Kafka version - 0.10.2 [cid:image001.png@01D4616F.405D2FA0] Thanks, Koushik

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Yishun Guan
Congrats Manikumar! On Thu, Oct 11, 2018 at 1:20 PM Sönke Liebau wrote: > > Great news, congratulations Manikumar!! > > On Thu, Oct 11, 2018 at 9:08 PM Vahid Hashemian > wrote: > > > Congrats Manikumar! > > > > On Thu, Oct 11, 2018 at 11:49 AM Ryanne Dolan > > wrote: > > > > > Bravo! > > > > >

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Sönke Liebau
Great news, congratulations Manikumar!! On Thu, Oct 11, 2018 at 9:08 PM Vahid Hashemian wrote: > Congrats Manikumar! > > On Thu, Oct 11, 2018 at 11:49 AM Ryanne Dolan > wrote: > > > Bravo! > > > > On Thu, Oct 11, 2018 at 1:48 PM Ismael Juma wrote: > > > > > Congratulations Manikumar! Thanks

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Vahid Hashemian
Congrats Manikumar! On Thu, Oct 11, 2018 at 11:49 AM Ryanne Dolan wrote: > Bravo! > > On Thu, Oct 11, 2018 at 1:48 PM Ismael Juma wrote: > > > Congratulations Manikumar! Thanks for your continued contributions. > > > > Ismael > > > > On Thu, Oct 11, 2018 at 10:39 AM Jason Gustafson > > wrote:

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Ryanne Dolan
Bravo! On Thu, Oct 11, 2018 at 1:48 PM Ismael Juma wrote: > Congratulations Manikumar! Thanks for your continued contributions. > > Ismael > > On Thu, Oct 11, 2018 at 10:39 AM Jason Gustafson > wrote: > > > Hi all, > > > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Ismael Juma
Congratulations Manikumar! Thanks for your continued contributions. Ismael On Thu, Oct 11, 2018 at 10:39 AM Jason Gustafson wrote: > Hi all, > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we > are > pleased to announce that he has accepted! > > Manikumar has

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Mickael Maison
Congrats Manikumar! On Thu, Oct 11, 2018 at 7:17 PM Dong Lin wrote: > > Congratulations Manikumar!! > > On Thu, Oct 11, 2018 at 10:39 AM Jason Gustafson wrote: > > > Hi all, > > > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we > > are > > pleased to announce that he

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Dong Lin
Congratulations Manikumar!! On Thu, Oct 11, 2018 at 10:39 AM Jason Gustafson wrote: > Hi all, > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we > are > pleased to announce that he has accepted! > > Manikumar has contributed 134 commits including significant work to

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Jun Rao
Congratulations, Mani! Jun On Thu, Oct 11, 2018 at 10:39 AM, Jason Gustafson wrote: > Hi all, > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we > are > pleased to announce that he has accepted! > > Manikumar has contributed 134 commits including significant work to

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Bill Bejeck
Congrats, Manikumar! On Thu, Oct 11, 2018 at 2:05 PM Rajini Sivaram wrote: > Congratulations, Manikumar! > > On Thu, Oct 11, 2018 at 6:57 PM Suman B N wrote: > > > Congratulations Manikumar! > > > > On Thu, Oct 11, 2018 at 11:09 PM Jason Gustafson > > wrote: > > > > > Hi all, > > > > > > The

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Renu Tewari
Congratulations Mani! Great work. renu On Thu, Oct 11, 2018 at 10:39 AM Jason Gustafson wrote: > Hi all, > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we > are > pleased to announce that he has accepted! > > Manikumar has contributed 134 commits including

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Rajini Sivaram
Congratulations, Manikumar! On Thu, Oct 11, 2018 at 6:57 PM Suman B N wrote: > Congratulations Manikumar! > > On Thu, Oct 11, 2018 at 11:09 PM Jason Gustafson > wrote: > > > Hi all, > > > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and > we > > are > > pleased to

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Suman B N
Congratulations Manikumar! On Thu, Oct 11, 2018 at 11:09 PM Jason Gustafson wrote: > Hi all, > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we > are > pleased to announce that he has accepted! > > Manikumar has contributed 134 commits including significant work to

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Guozhang Wang
Congratulations Manikumar ! Guozhang On Thu, Oct 11, 2018 at 10:39 AM, Jason Gustafson wrote: > Hi all, > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we > are > pleased to announce that he has accepted! > > Manikumar has contributed 134 commits including

[ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Jason Gustafson
Hi all, The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we are pleased to announce that he has accepted! Manikumar has contributed 134 commits including significant work to add support for delegation tokens in Kafka: KIP-48:

Kafka UnknownProducerIdException

2018-10-11 Thread Faisal Durrani
Does anyone know the reason for the below error in Kafka? I have a Golden gate server publishing change transaction of tables to its corresponding topics in Kafka (which is running with the default configuration).It is a multi node cluster but the topic mentioned in the error has a single

How to manage Kafka quota configuration with java code?

2018-10-11 Thread SJTU胡昊坤
Hi community, I'm trying to implement quota configuration function in my own kafka portal program written in Spring Boot. I found out that there is no API for me to do that. So I read the source code and here is my way: write {"version":1,"config":{"producer_byte_rate":"1000"}} with path

Re: Why is segment.ms=10m for repartition topics in KafkaStreams?

2018-10-11 Thread Niklas Lönn
Hi again, On another note, does it really make much sense to limit by time this way? wouldn't it be sufficient with just the 50mb? In use-cases like ours, restarting/rebuilding the state opened almost 30K extra files on each broker (It seems it is doing the repartitioning much faster than the

Question about Kafka uptime

2018-10-11 Thread Kabessa, Itzik
Hi, We are using a dockerized version of Kafka : https://github.com/wurstmeister/kafka-docker We deploy using ECS on AWS machines. We have "tests" in our system, and for each "test" we have new Kafka and Zookeeper brokers (for security reasons, it's a must). We run on EC2, and using Elastic

AW: Problems with broker upgrade from 1.1.0 to 2.0.0

2018-10-11 Thread Claudia Wegmann
Thanks for the quick answer, Bratt. You are right, my brokers did not shut down cleanly. The issue was not related to the update. Thanks for the pointers! Best, Claudia -Ursprüngliche Nachricht- Von: Brett Rann Gesendet: Dienstag, 9. Oktober 2018 03:26 An: Users Betreff: Re:

Batch processing with Kafka Streams with at-least-once semantics

2018-10-11 Thread Tomoyuki Saito
Hi, I'm exploring whether it is possible to use Kafka Streams for batch processing with at-least-once semantics. What I want to do is to insert records in an external storage in bulk, and execute offset-commit after the bulk insertion to achieve at-least-once semantics. A processing topology can