Build failed in Jenkins: kafka-trunk-jdk11 #1158

See Changes: [github] KAFKA-8507; Unify connection name flag for command line tool [KIP-499] -- [...truncated 1.56 MB...] kafka.zookeeper.ZooKeeperClientTest > testExcep

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

See Changes: [github] HOTFIX: Fix breakage in `ConsumerPerformanceTest` (#8113) -- [...truncated 2.88 MB...] org.apache.kafka.streams.MockTimeTest > shouldGetNanosAsMilli

Build failed in Jenkins: kafka-2.4-jdk8 #144

See Changes: [wangguoz] KAFKA-9355: Fix bug that removed RocksDB metrics after failure in EOS [wangguoz] HOTFIX: cherry-pick conflicts -- [...truncated 2.75 MB...] org.apac

[jira] [Created] (KAFKA-9553) Transaction state loading metric does not count total loading time

Jason Gustafson created KAFKA-9553: -- Summary: Transaction state loading metric does not count total loading time Key: KAFKA-9553 URL: https://issues.apache.org/jira/browse/KAFKA-9553 Project: Kafka

[jira] [Resolved] (KAFKA-7381) Parameterize connector rebalancing behavior

[ https://issues.apache.org/jira/browse/KAFKA-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-7381. --- Resolution: Fixed Marking as {{Fixed}} by [#KAFKA-5505] > Parameterize conne

[jira] [Resolved] (KAFKA-5866) Let source/sink task to finish their job before exit

[ https://issues.apache.org/jira/browse/KAFKA-5866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-5866. --- Resolution: Won't Do I'm closing this ticket, as this is a quite old request

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

See Changes: [github] KAFKA-8507; Unify connection name flag for command line tool [KIP-499] -- [...truncated 2.68 MB...] org.apache.kafka.streams.test.ConsumerRecordFact

Re: [VOTE] KIP-568: Explicit rebalance triggering on the Consumer

+1 (non-binding) On Thu, Feb 13, 2020 at 4:45 PM Guozhang Wang wrote: > +1 (binding). > > > Guozhang > > On Tue, Feb 11, 2020 at 5:29 PM Guozhang Wang wrote: > > > Hi Sophie, > > > > Thanks for the KIP, I left some comments on the DISCUSS thread. > > > > > > Guozhang > > > > > > On Tue, Feb 11,

[jira] [Resolved] (KAFKA-9446) Integration test library should provide utilities to assert connector state

[ https://issues.apache.org/jira/browse/KAFKA-9446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-9446. -- Resolution: Fixed > Integration test library should provide utilities to assert connector state

Re: [VOTE] KIP-568: Explicit rebalance triggering on the Consumer

+1 (binding). Guozhang On Tue, Feb 11, 2020 at 5:29 PM Guozhang Wang wrote: > Hi Sophie, > > Thanks for the KIP, I left some comments on the DISCUSS thread. > > > Guozhang > > > On Tue, Feb 11, 2020 at 3:25 PM Bill Bejeck wrote: > >> Thanks for the KIP Sophie. >> >> It's a +1 (binding) for me

Re: [DISCUSS] KIP-568: Explicit rebalance triggering on the Consumer

Thanks Sophie, I think for KIP-441 the streams client would not need to rely on the returned boolean flag so I was a bit confused before. Now I understand it is for other use cases where users do not (or cannot) rely on the returned assignment to decide if a rebalance is still requested so checking

Re: [Discuss] KIP-571: Add option to force remove members in StreamsResetter

Thanks for driving this change Feyman! Hope this is a good name to call you :) The motivation of the KIP looks good, and I have a couple of initial thoughts: 1. I guess the reason to use setters instead of adding a new constructor to MemberToRemove class is because we have two String members. Coul

[jira] [Resolved] (KAFKA-7644) Worker Re balance enhancements

[ https://issues.apache.org/jira/browse/KAFKA-7644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-7644. --- Resolution: Duplicate > Worker Re balance enhancements >

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

See Changes: [github] KAFKA-9106 make metrics exposed via jmx configurable (#7674) -- [...truncated 5.81 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest >

Build failed in Jenkins: kafka-trunk-jdk11 #1157

See Changes: [github] KAFKA-9106 make metrics exposed via jmx configurable (#7674) -- [...truncated 2.90 MB...] org.apache.kafka.streams.TopologyTestDriverTest > should

[jira] [Created] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

Boyang Chen created KAFKA-9552: -- Summary: Stream should handle OutOfSequence exception thrown from Producer Key: KAFKA-9552 URL: https://issues.apache.org/jira/browse/KAFKA-9552 Project: Kafka

[jira] [Created] (KAFKA-9551) Alternate WindowKeySchema Implementations

Michael Viamari created KAFKA-9551: -- Summary: Alternate WindowKeySchema Implementations Key: KAFKA-9551 URL: https://issues.apache.org/jira/browse/KAFKA-9551 Project: Kafka Issue Type: Impro

[jira] [Created] (KAFKA-9550) RemoteLogManager implementation

Satish Duggana created KAFKA-9550: - Summary: RemoteLogManager implementation Key: KAFKA-9550 URL: https://issues.apache.org/jira/browse/KAFKA-9550 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-9549) Local storage implementations for RSM and RLMM which can be used in tests.

Satish Duggana created KAFKA-9549: - Summary: Local storage implementations for RSM and RLMM which can be used in tests. Key: KAFKA-9549 URL: https://issues.apache.org/jira/browse/KAFKA-9549 Project: K

[jira] [Created] (KAFKA-9548) RemoteStorageManager and RemoteLogMetadataManager interfaces.

Satish Duggana created KAFKA-9548: - Summary: RemoteStorageManager and RemoteLogMetadataManager interfaces. Key: KAFKA-9548 URL: https://issues.apache.org/jira/browse/KAFKA-9548 Project: Kafka

Re: [DISCUSS] KIP-518: Allow listing consumer groups per state

Hi Colin, > Can you please specify what the result is when a newer client tries to use > this on an older broker? Does that result in an > UnsupportedVersionException? Yes, in case this feature is not supported by the broker, UnsupportedVersionException should be raised. Your question made me loo

Build failed in Jenkins: kafka-trunk-jdk11 #1156

See Changes: [github] MINOR: Do not override retries for idempotent producers (#8097) -- [...truncated 2.89 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTes

Re: [DISCUSS] KIP-501 Avoid out-of-sync or offline partitions when follower fetch requests not processed in time

Hi Lucas, Thanks for looking into the KIP and providing your comments. Adding to what Harsha mentioned, I do not think there is a fool proof solution here to solve the cases like pending requests in the request queue. We also thought about the option of relinquishing the leadership but the followe

Build failed in Jenkins: kafka-trunk-jdk11 #1155

See Changes: [github] KAFKA-9538; Fix flaky test `testResetOffsetsExportImportPlan` (#6561) -- [...truncated 5.85 MB...] org.apache.kafka.streams.internals.WindowStoreFa

[jira] [Created] (KAFKA-9547) Kafka transaction - skip one offset when the application stops and be started again

Rumel created KAFKA-9547: Summary: Kafka transaction - skip one offset when the application stops and be started again Key: KAFKA-9547 URL: https://issues.apache.org/jira/browse/KAFKA-9547 Project: Kafka

[jira] [Created] (KAFKA-9546) Make FileStreamSourceTask extendable with generic streams

Csaba Galyo created KAFKA-9546: -- Summary: Make FileStreamSourceTask extendable with generic streams Key: KAFKA-9546 URL: https://issues.apache.org/jira/browse/KAFKA-9546 Project: Kafka Issue Typ

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

See Changes: [github] MINOR: Do not override retries for idempotent producers (#8097) -- [...truncated 2.87 MB...] org.apache.kafka.streams.MockTimeTest > shouldGetNanosA

[Discuss] KIP-571: Add option to force remove members in StreamsResetter

Hi, all In order to make it possible for StreamsResetter to reset stream even when there are active members, since we currently only have the ability to remove static members, so we basically need the ability to remove dynamic members, this involves some public interfaces change in org.apac

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

See Changes: [github] KAFKA-9538; Fix flaky test `testResetOffsetsExportImportPlan` (#6561) -- [...truncated 2.87 MB...] org.apache.kafka.streams.MockTimeTest > shouldGet