Re: Unable to build project in intelliji

Apache Kafka uses Gradle as build tool so: First create gradle wrapper using instructions here : https://github.com/apache/kafka#first-bootstrap-and-download-the-wrapper And then execute "gradlew idea" as mentioned here : https://github.com/apache/kafka#building-ide-project On Wed, May 22, 2019 at

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

; > +1 binding. Thanks for the KIP! > > > > > > > > -Ewen > > > > > > > > On Mon, Jan 8, 2018 at 8:34 AM, Ted Yu wrote: > > > > > > > > > +1 > > > > > > > > > > On Mon, Jan 8, 2018 at

Re: [ANNOUNCE] New committer: Matthias J. Sax

Congratulations Matthias :) On Mon, 15 Jan 2018 at 17:06 Michael Noll wrote: > Herzlichen Glückwunsch, Matthias. ;-) > > > > On Mon, 15 Jan 2018 at 11:38 Viktor Somogyi > wrote: > > > Congrats Matthias! > > > > On Mon, Jan 15, 2018 at 9:17 AM, Jorge Esteban Quilcate Otoya < > > quilcate.jo...@g

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

Hello All, Since there are no outstanding comments on this, so I'd like to start a vote. Please find the KIP here and the related JIRA here

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

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 > wrote: > >> Thanks Ewen, >> I just edited the KIP to reflect the changes. >> >> Regards,

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 wrote: > > > Congrats O

Re: [ANNOUNCE] Apache Kafka 1.0.0 Released

Erik Kringen, Erkan Unal, Evgeny > Veretennikov, > > Ewen Cheslack-Postava, Florian Hussonnois, Janek P, Gregor Uhlenheuer, > > Guozhang Wang, Gwen Shapira, Hamidreza Afzali, Hao Chen, Jiefang He, > Holden > > Karau, Hooman Broujerdi, Hugo Louro, Ismael Juma, Jacek Laskowski, J

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

uot; > 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 8, 2017 at 2:54 AM

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 wrote: > On Sun, Jul 30, 2017 at 10:21 PM, UMESH CHAUDHARY > wrote: > >> Hi

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

; migrate to newer versions which would no longer support that? > > -Ewen > > > On Fri, Jul 14, 2017 at 2:37 AM, UMESH CHAUDHARY > wrote: > > > Hi there, > > Resending as probably missed earlier to grab your attention. > > > > Regards, > > Umesh &g

[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 Date: Mon, 3 Jul 2017 at 11:04 Subject: [DISCUSS] KIP-174 - Deprecate and remove internal converter configs in WorkerConfig To: dev@kafka.apache.org

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

Hello All, I have added a KIP recently to deprecate and remove internal converter configs in WorkerConfig.java class because these have ultimately just caused a lot more trouble and confusion than it is worth. Please find the KIP here

[jira] [Commented] (KAFKA-5093) Load only batch header when rebuilding producer ID map

[ https://issues.apache.org/jira/browse/KAFKA-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027696#comment-16027696 ] Umesh Chaudhary commented on KAFKA-5093: No worries at all [~hachi

[jira] [Commented] (KAFKA-5093) Load only batch header when rebuilding producer ID map

[ https://issues.apache.org/jira/browse/KAFKA-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027362#comment-16027362 ] Umesh Chaudhary commented on KAFKA-5093: Tried to co-relate it with KIP but

[jira] [Assigned] (KAFKA-5171) TC should not accept empty string transactional id

[ https://issues.apache.org/jira/browse/KAFKA-5171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned KAFKA-5171: -- Assignee: Umesh Chaudhary > TC should not accept empty string transactional

[jira] [Assigned] (KAFKA-4660) Improve test coverage KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-4660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned KAFKA-4660: -- Assignee: Umesh Chaudhary > Improve test coverage KafkaStre

[jira] [Commented] (KAFKA-5025) FetchRequestTest should use batches with more than one message

[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010242#comment-16010242 ] Umesh Chaudhary commented on KAFKA-5025: Hi [~ijuma], I executed the above

Re: Permission request to create a KIP

Thank you Ewen! Now, I can create child page under "Apache Kafka". Regards, Umesh On Fri, 5 May 2017 at 10:52 Ewen Cheslack-Postava wrote: > Umesh, > > I've given you permissions on the wiki. Let me know if you run into any > issues. > > -Ewen > >

Permission request to create a KIP

Hello Mates, I need to start a KIP for KAFKA-5057 under this wiki page but looks like I don't have sufficient permissions to create a child page under "Apache Kafka" sp

[jira] [Commented] (KAFKA-5171) TC should not accept empty string transactional id

[ https://issues.apache.org/jira/browse/KAFKA-5171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996180#comment-15996180 ] Umesh Chaudhary commented on KAFKA-5171: [~guozhang] , Please review th

[jira] [Commented] (KAFKA-5137) Controlled shutdown timeout message improvement

[ https://issues.apache.org/jira/browse/KAFKA-5137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988235#comment-15988235 ] Umesh Chaudhary commented on KAFKA-5137: Indeed [~cotedm]. Even

[jira] [Comment Edited] (KAFKA-5025) FetchRequestTest should use batches with more than one message

[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982953#comment-15982953 ] Umesh Chaudhary edited comment on KAFKA-5025 at 4/28/17 4:5

[jira] [Commented] (KAFKA-5132) Abort long running transactions

[ https://issues.apache.org/jira/browse/KAFKA-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15988198#comment-15988198 ] Umesh Chaudhary commented on KAFKA-5132: Sure [~damianguy]. Can unders

[jira] [Commented] (KAFKA-5132) Abort long running transactions

[ https://issues.apache.org/jira/browse/KAFKA-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986115#comment-15986115 ] Umesh Chaudhary commented on KAFKA-5132: Hi [~damianguy] , can I attempt this

[jira] [Commented] (KAFKA-5025) FetchRequestTest should use batches with more than one message

[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15982953#comment-15982953 ] Umesh Chaudhary commented on KAFKA-5025: [~ijuma], taking this one to star

[jira] [Assigned] (KAFKA-5025) FetchRequestTest should use batches with more than one message

[ https://issues.apache.org/jira/browse/KAFKA-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Umesh Chaudhary reassigned KAFKA-5025: -- Assignee: Umesh Chaudhary > FetchRequestTest should use batches with more than

[jira] [Commented] (KAFKA-5114) Clarify meaning of logs in Introduction: Topics and Logs

[ https://issues.apache.org/jira/browse/KAFKA-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980644#comment-15980644 ] Umesh Chaudhary commented on KAFKA-5114: IMHO, it has a co-relation with

[jira] [Commented] (KAFKA-5098) KafkaProducer.send() blocks and generates TimeoutException if topic name has illegal char

[ https://issues.apache.org/jira/browse/KAFKA-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979910#comment-15979910 ] Umesh Chaudhary commented on KAFKA-5098: I will reproduce and work on

[jira] [Commented] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969873#comment-15969873 ] Umesh Chaudhary commented on KAFKA-5049: [~anukin] I tried to assign this to

[jira] [Commented] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969805#comment-15969805 ] Umesh Chaudhary commented on KAFKA-5049: [~anukin] you can send a PR and

[jira] [Commented] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968624#comment-15968624 ] Umesh Chaudhary commented on KAFKA-5049: Thanks [~junrao] for the pointers. W

[jira] [Commented] (KAFKA-5057) "Big Message Log"

[ https://issues.apache.org/jira/browse/KAFKA-5057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15968580#comment-15968580 ] Umesh Chaudhary commented on KAFKA-5057: Understood and yes this is a good

[jira] [Commented] (KAFKA-5057) "Big Message Log"

[ https://issues.apache.org/jira/browse/KAFKA-5057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965615#comment-15965615 ] Umesh Chaudhary commented on KAFKA-5057: [~gwenshap] currently we

[jira] [Commented] (KAFKA-4737) Streams apps hang if started when brokers are not available

[ https://issues.apache.org/jira/browse/KAFKA-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15853424#comment-15853424 ] Umesh Chaudhary commented on KAFKA-4737: No worries. Thanks [~gwen

[jira] [Commented] (KAFKA-4737) Streams apps hang if started when brokers are not available

[ https://issues.apache.org/jira/browse/KAFKA-4737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15853422#comment-15853422 ] Umesh Chaudhary commented on KAFKA-4737: Hi [~gwenshap], does the inten

[jira] [Comment Edited] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable

[ https://issues.apache.org/jira/browse/KAFKA-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15813892#comment-15813892 ] Umesh Chaudhary edited comment on KAFKA-4569 at 1/10/17 9:1

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814359#comment-15814359 ] Umesh Chaudhary commented on KAFKA-4564: Hi [~guozhang], [~ewencp], I am thin

[jira] [Commented] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable

[ https://issues.apache.org/jira/browse/KAFKA-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15813892#comment-15813892 ] Umesh Chaudhary commented on KAFKA-4569: Hi [~ijuma], One observation regar

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15793810#comment-15793810 ] Umesh Chaudhary commented on KAFKA-4564: Thank you [~ewencp]. > W

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15792067#comment-15792067 ] Umesh Chaudhary commented on KAFKA-4564: Hi [~guozhang], please assign this t

[jira] [Commented] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable

[ https://issues.apache.org/jira/browse/KAFKA-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15792055#comment-15792055 ] Umesh Chaudhary commented on KAFKA-4569: Hi [~guozhang], I can work on

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582838#comment-15582838 ] Umesh Chaudhary commented on KAFKA-4308: Sure Andrew, can you please assign

[jira] [Commented] (KAFKA-4308) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15582819#comment-15582819 ] Umesh Chaudhary commented on KAFKA-4308: Hi [~gwenshap], I would like to wor

[jira] [Commented] (KAFKA-4122) Consumer startup swallows DNS resolution exception and infinitely retries

[ https://issues.apache.org/jira/browse/KAFKA-4122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531969#comment-15531969 ] Umesh Chaudhary commented on KAFKA-4122: This one looks feasible. [~ju

[jira] [Commented] (KAFKA-4142) Log files in /data dir date modified keeps being updated?

[ https://issues.apache.org/jira/browse/KAFKA-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15531931#comment-15531931 ] Umesh Chaudhary commented on KAFKA-4142: [~cmhillerman], Did you compare the

Unable to locate auto.create.topics.enable=true path for KafkaProducer

Hi Mates, I was trying to understand that if auto.create.topics.enable=true then how KafkaProducer first creates the topic and sends messages to it. What I saw: private Future doSend(ProducerRecord record, Callback callback) method in KafkaProducer.java. What I failed to get: When getting meta

[jira] [Commented] (KAFKA-4189) Consumer poll hangs forever if kafka is disabled

[ https://issues.apache.org/jira/browse/KAFKA-4189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15509565#comment-15509565 ] Umesh Chaudhary commented on KAFKA-4189: Yep, [Guozhang's comm

[jira] [Commented] (KAFKA-4189) Consumer poll hangs forever if kafka is disabled

[ https://issues.apache.org/jira/browse/KAFKA-4189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15502860#comment-15502860 ] Umesh Chaudhary commented on KAFKA-4189: Is it similar to [KAFKA-1894|h

WIKI page outdated

Hello Mates, I may be reiterating the previously identified issue here so please forgive me if you find it noisy. The page : https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+Producer+Example# is having Producer example which is seems to be outdated but having "partitioner.class" property wh

[jira] [Commented] (KAFKA-4053) Refactor TopicCommand to remove redundant if/else statements

[ https://issues.apache.org/jira/browse/KAFKA-4053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15424224#comment-15424224 ] Umesh Chaudhary commented on KAFKA-4053: I will do that. Please assign it t