Re: [DISCUSS] KIP-211: Revise Expiration Semantics of Consumer Group Offsets

Hi Jason, Thanks a lot for reviewing the KIP. 1. I think my suggestion in the KIP was more towards ignoring the client provided values and use a large enough broker config value instead. It seems the question comes down to whether we still want to honor the `retention_time` field in the old

Build failed in Jenkins: kafka-trunk-jdk8 #2434

See Changes: [github] MINOR: Revert incompatible behavior change to consumer reset tool -- [...truncated 3.50 MB...] kafka.zookeeper.ZooKeeperClientTest >

Build failed in Jenkins: kafka-0.11.0-jdk7 #360

See Changes: [matthias] MINOR: wait for broker startup for system tests (#4363) -- [...truncated 905.10 KB...] kafka.producer.AsyncProducerTest > testFailedSendRetryLogic

[jira] [Resolved] (KAFKA-6239) Consume group hung into rebalancing state, now stream not able to poll data

[ https://issues.apache.org/jira/browse/KAFKA-6239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6239. -- Resolution: Duplicate > Consume group hung into rebalancing state, now stream

[jira] [Resolved] (KAFKA-6236) stream not picking data from topic - after rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-6236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6236. -- Resolution: Cannot Reproduce Unresponsive, so we can't track this down. Please

[jira] [Resolved] (KAFKA-6328) Exclude node groups belonging to global stores in InternalTopologyBuilder#makeNodeGroups

[ https://issues.apache.org/jira/browse/KAFKA-6328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6328. -- Resolution: Fixed Fix Version/s: 1.1.0 > Exclude node groups belonging to global stores

[jira] [Created] (KAFKA-6589) Extract Heartbeat thread from Abstract Coordinator for testability purposes

Guozhang Wang created KAFKA-6589: Summary: Extract Heartbeat thread from Abstract Coordinator for testability purposes Key: KAFKA-6589 URL: https://issues.apache.org/jira/browse/KAFKA-6589 Project:

Re: [VOTE] 1.0.1 RC2

+1. Ran the quickstart with the binary release of scala 2.12. Guozhang On Fri, Feb 23, 2018 at 1:02 PM, Vahid S Hashemian < vahidhashem...@us.ibm.com> wrote: > +1 > > Built source and ran quickstarts successfully on Ubuntu and Windows 64bit. > > Thanks. > --Vahid > > > > > From: Damian Guy

Jenkins build is back to normal : kafka-1.1-jdk7 #62

See

Re: [DISCUSS] KIP-261: Add Single Value Fetch in Window Stores

Hi all, I'd like to hear more feedbacks on this KIP. If there is no more I'm going to start the vote thread by tonight. Guozhang On Fri, Feb 23, 2018 at 8:52 AM, Damian Guy wrote: > Thanks Guozhang. +1 > > On Thu, 22 Feb 2018 at 23:44 Guozhang Wang

[jira] [Resolved] (KAFKA-4498) Extract Streams section as a separate page from documentation.html

[ https://issues.apache.org/jira/browse/KAFKA-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4498. -- Resolution: Fixed Assignee: Guozhang Wang Fix Version/s: 0.10.1.0 > Extract

[jira] [Resolved] (KAFKA-6439) "com.streamsets.pipeline.api.StageException: KAFKA_50 - Error writing data to the Kafka broker: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.N

[ https://issues.apache.org/jira/browse/KAFKA-6439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6439. -- Resolution: Not A Bug > "com.streamsets.pipeline.api.StageException: KAFKA_50 -

Jenkins build is back to normal : kafka-trunk-jdk8 #2435

See

Re: [DISCUSS] KIP-253: Support in-order message delivery with partition expansion

Hey all, Thanks much for all the comments. I have a rough idea of how to shrink partitions of a topic. I need some time to think through and write down the details of the procedure. Then I will reply to your comments. Thanks, Dong On Thu, Feb 22, 2018 at 7:18 PM, Matthias J. Sax

Jenkins build is back to normal : kafka-trunk-jdk9 #428

See

Build failed in Jenkins: kafka-1.1-jdk7 #61

See Changes: [jason] MINOR: Fix ConcurrentModificationException in TransactionManager (#4608) [jason] KAFKA-6578: Changed the Connect distributed and standalone main method

[jira] [Resolved] (KAFKA-2544) Replication tools wiki page needs to be updated

[ https://issues.apache.org/jira/browse/KAFKA-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakub Scholz resolved KAFKA-2544. - Resolution: Fixed Assignee: Jakub Scholz This issue has been resolved. > Replication tools

Re: [DISCUSS] KIP-261: Add Single Value Fetch in Window Stores

Thanks Guozhang. +1 On Thu, 22 Feb 2018 at 23:44 Guozhang Wang wrote: > Thanks Ted, have updated the wiki page. > > On Thu, Feb 22, 2018 at 1:48 PM, Ted Yu wrote: > > > +1 > > > > There were some typos: > > CachingWindowedStore -> CachingWindowStore > >

[jira] [Created] (KAFKA-6587) Kafka Streams hangs when not able to access internal topics

Chris Medved created KAFKA-6587: --- Summary: Kafka Streams hangs when not able to access internal topics Key: KAFKA-6587 URL: https://issues.apache.org/jira/browse/KAFKA-6587 Project: Kafka

[jira] [Created] (KAFKA-6588) Add a metric to monitor live log cleaner thread

Navina Ramesh created KAFKA-6588: Summary: Add a metric to monitor live log cleaner thread Key: KAFKA-6588 URL: https://issues.apache.org/jira/browse/KAFKA-6588 Project: Kafka Issue Type:

Re: [VOTE] 1.0.1 RC2

+1 Built source and ran quickstarts successfully on Ubuntu and Windows 64bit. Thanks. --Vahid From: Damian Guy To: dev@kafka.apache.org Date: 02/23/2018 01:42 AM Subject:Re: [VOTE] 1.0.1 RC2 +1 Built src and ran tests Ran streams quickstart On Thu,

Jenkins build is back to normal : kafka-trunk-jdk8 #2433

See

Re: [VOTE] 1.0.1 RC2

+1 Built src and ran tests Ran streams quickstart On Thu, 22 Feb 2018 at 21:32 Ted Yu wrote: > +1 > > MetricsTest#testMetricsLeak failed but it is flaky test > > On Wed, Feb 21, 2018 at 4:06 PM, Ewen Cheslack-Postava > wrote: > > > Hello Kafka users,

Re: [VOTE] 1.0.1 RC2

Hi there, Here is what I did: - Verified signature and hashes - Built kafka from source - Executed tests - all passed - Started Zookeeper, Kafka broker, a console producer and consumer. Verified that the stream of records published to my test Kafka topic was processed - Ran the Kafka Streams demo