Re: [kafka-clients] [VOTE] 2.5.0 RC3

Hello, I have ran the tests (passed) Follow the quick start guide with scala 2.12 (success) +1 Thanks! -- Jonathan On Tue, Apr 14, 2020 at 1:16 AM Colin McCabe wrote: > +1 (binding) > > verified checksums > ran unitTest > ran check > > best, > Colin > > On Tue, Apr 7, 2020, at 21:03, David

Re: [ANNOUNCE] Apache Kafka 2.2.1

That's fantastic! thanks a lot Vahid for managing the release. -- Jonathan On Mon, Jun 3, 2019 at 5:18 PM Mickael Maison wrote: > Thank you Vahid > > On Mon, Jun 3, 2019 at 5:12 PM Wladimir Schmidt > wrote: > > > > Thanks Vahid! > > > > On Mon, Jun 3, 2019, 16:23 Vahid Hashemian wrote: >

Re: [kafka-clients] Re: [VOTE] 2.2.1 RC1

Hello, I have run the tests, all tests passed. I have also run the quick start and test my apps with that commit 55783d313, everything worked. +1 Thanks a lot for the release, I have been waiting for a bug fix on this release for long, yuju! :) Cheers! -- Jonathan On Sat, May 18, 2019 at

Re: [VOTE] 2.2.1 RC0

Hello Vahid, am testing one of our Kafka Stream Apps with the 2.2.1-rc, after few minutes, I see this WARN: 2019-05-09 13:14:37,025 WARN [test-app-id-dc27624a-8e02- 4031-963b-7596a8a77097-StreamThread-1] internals.ProcessorStateManager ( ProcessorStateManager.java:349) - task [0_0] Failed to

Re: Kafka point in time recovery?

Hello Kumar, if I got it correctly, you can try with the method offsetsForTimes from the KafkaConsumer Api. Maybe you can reset the offset to a particular timestamp and consume up to a certain offset or timestamp.

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Definitely well deserved! Congrats Matthias! On Thu, Apr 18, 2019, 10:46 PM Bill Bejeck wrote: > Congrats Matthias! Well deserved! > > -Bill > > On Thu, Apr 18, 2019 at 5:35 PM Guozhang Wang wrote: > > > Hello Everyone, > > > > I'm glad to announce that Matthias J. Sax is now a member of Kafka

Re: [VOTE] 2.2.0 RC1

Hello Matthias, I have run the tests without issue. Also, I have performed the quick start successfully, thanks for the release. Cheers! -- Jonathan On Wed, Mar 6, 2019 at 8:58 PM Matthias J. Sax wrote: > Thanks for testing the RC Jakub! > > I agree, that both issue are no reason to cancel

Re: [kafka-clients] [VOTE] 2.1.1 RC2

Hello, I have downloaded the source and executed integration and unit tests successfully. Ran kafka-monitor for about 1 hour without any issues. +1 Thanks for the release Colin. -- Jonathan Santilli On Fri, Feb 15, 2019 at 6:16 AM Jason Gustafson wrote: > Ran the quickstart agai

Re: [VOTE] 2.1.1 RC1

-2.1.1.tgz and ran a cluster of 3 Brokers. Kept Kafka-monitor running for about 1 hour without any issues. +1 Thanks for the release Colin. -- Jonathan Santilli On Wed, Jan 30, 2019 at 8:18 PM Eno Thereska wrote: > I couldn't repro locally, that was on an m3.large. And it's not happen

DisconnectException stop Kafka Stream app consuming from topic

Hello, hope you all are great today! am using a Kafka Stream application: ... *final* StreamsBuilder streamsBuilder = *new* StreamsBuilder(); *final* KStream, MyObject> myObjects = streamsBuilder .stream(inputTopicNames, Consumed.*with*( myObjectsWindowSerde,

[jira] [Resolved] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-7508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli resolved KAFKA-7508. -- Resolution: Not A Problem Closed since was requested by the reported. Sathish agree

[jira] [Created] (KAFKA-7678) Failed to close producer due to java.lang.NullPointerException

Jonathan Santilli created KAFKA-7678: Summary: Failed to close producer due to java.lang.NullPointerException Key: KAFKA-7678 URL: https://issues.apache.org/jira/browse/KAFKA-7678 Project: Kafka

Re: [VOTE] 2.1.0 RC1

Hello, +1 I have downloaded the release artifact from http://home.apache.org/~lindong/kafka-2.1.0-rc1/ Executed a 3 brokers cluster. (java8 8u192b12) Executed kafka-monitor for about 1 hour without problems. Thanks, -- Jonathan On Fri, Nov 9, 2018 at 11:33 PM Dong Lin wrote: > Hello Kafka

[jira] [Resolved] (KAFKA-4277) creating ephemeral node already exist

[ https://issues.apache.org/jira/browse/KAFKA-4277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli resolved KAFKA-4277. -- Resolution: Duplicate This is getting closed since KAFKA-7165 have been solved

[jira] [Resolved] (KAFKA-5971) Broker keeps running even though not registered in ZK

[ https://issues.apache.org/jira/browse/KAFKA-5971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Santilli resolved KAFKA-5971. -- Resolution: Duplicate This is getting closed since KAFKA-7165 have been solved

Access to Jira

Hello, am working on KAFKA-7165 , one of the steps is to assign the Jira issue to myself, but am not allowed, I would like to have Jira access to do it, please. Cheers! -- Santilli Jonathan

[jira] [Created] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

Jonathan Santilli created KAFKA-7165: Summary: Error while creating ephemeral at /brokers/ids/BROKER_ID Key: KAFKA-7165 URL: https://issues.apache.org/jira/browse/KAFKA-7165 Project: Kafka