Permission to create KIP

Hi, I'd like permission to create a KIP on the Apache Kafka Wiki. My WikiID is Jiamei.xie Best wishes Jiamei Xie IMPORTANT NOTICE: The contents of this email and any attachments are confidential and may also be privileged. If you are not the intended recipient, please notify the sender

[jira] [Resolved] (KAFKA-10165) Percentiles metric leaking memory

[ https://issues.apache.org/jira/browse/KAFKA-10165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10165. -- Resolution: Fixed > Percentiles metric leaking memory > - > >

[jira] [Reopened] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9509: Saw this fail again on a PR build: h3. Stacktrace java.lang.RuntimeException: Could

[jira] [Resolved] (KAFKA-10151) Flaky Test StoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapi

[ https://issues.apache.org/jira/browse/KAFKA-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-10151. - Fix Version/s: 2.6.0 Resolution: Fixed > Flaky Test >

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

See Changes: [github] KAFKA-10165: Remove Percentiles from e2e metrics (#8882) [github] KAFKA-10147 MockAdminClient#describeConfigs(Collection) [github] MINOR: Fix flaky

Build failed in Jenkins: kafka-trunk-jdk14 #224

See Changes: [github] KAFKA-10165: Remove Percentiles from e2e metrics (#8882) -- [...truncated 3.17 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Created] (KAFKA-10180) TLSv1.3 system tests should not run under Java 8

Ron Dagostino created KAFKA-10180: - Summary: TLSv1.3 system tests should not run under Java 8 Key: KAFKA-10180 URL: https://issues.apache.org/jira/browse/KAFKA-10180 Project: Kafka Issue

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

See Changes: [github] KAFKA-10147 MockAdminClient#describeConfigs(Collection) [github] MINOR: Fix flaky HighAvailabilityTaskAssignorIntegrationTest (#8884) [github] MINOR: Upgrade jetty to 9.4.27.v20200227

Build failed in Jenkins: kafka-trunk-jdk14 #225

See Changes: [github] KAFKA-10147 MockAdminClient#describeConfigs(Collection) [github] MINOR: Fix flaky HighAvailabilityTaskAssignorIntegrationTest (#8884) [github] MINOR: Upgrade jetty to 9.4.27.v20200227 and

[DISCUSS] KIP-627: Expose Trogdor-specific JMX Metrics for Tasks and Agents

Hi all, I’d like to start a discussion about adding metrics to Trogdor to track valuable information about agents and tasks. Specifically, exposing metrics about the number of active agents and the number of created, running, and done tasks in a Trogdor cluster. KIP: KIP-627

[jira] [Created] (KAFKA-10179) State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables

Bruno Cadonna created KAFKA-10179: - Summary: State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables Key: KAFKA-10179 URL: https://issues.apache.org/jira/browse/KAFKA-10179

Re: Questions regarding MirrorMaker 2.0

Thanks Ryanne for your quick reply. I have reached out the KIP owner for status and pending work on this. He has created draft PR also for this and you have reviewed it. https://github.com/apache/kafka/pull/8604/files I did launch a sample consumer but still the MBeans were not created. I will

[jira] [Resolved] (KAFKA-10147) MockAdminClient#describeConfigs(Collection) is unable to handle broker resource

[ https://issues.apache.org/jira/browse/KAFKA-10147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-10147. --- Fix Version/s: 2.7.0 Reviewer: Boyang Chen Resolution: Fixed Merged to

[jira] [Created] (KAFKA-10178) MM2 to provide configuration parameter to specify NIC/IP address to use for produce/consumerequests

Sudarshan Pathalam created KAFKA-10178: -- Summary: MM2 to provide configuration parameter to specify NIC/IP address to use for produce/consumerequests Key: KAFKA-10178 URL:

Re: [DISCUSS] KIP-487: Automatic Topic Creation on Producer

Hi all For https://cwiki.apache.org/confluence/display/KAFKA/KIP-487%3A+Client-side+Automatic+Topic+Creation+on+Producer , It has not been updated for a long time. And I made some update, which has been pushed to https://github.com/apache/kafka/pull/8831 MetadataRequest has method

Build failed in Jenkins: kafka-2.6-jdk8 #49

See Changes: [vvcephei] KAFKA-10165: Remove Percentiles from e2e metrics (#8882) -- [...truncated 3.14 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Re: [DISCUSS] KIP-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter

Hi all, I have contacted Mateusz separately and he is ok for me to take over KIP-431: https://cwiki.apache.org/confluence/display/KAFKA/KIP-431%3A+Support+of+printing+additional+ConsumerRecord+fields+in+DefaultMessageFormatter I have updated it a bit. Can anyone give a quick look at it again

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

See Changes: [github] KAFKA-10165: Remove Percentiles from e2e metrics (#8882) -- [...truncated 3.17 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Reopened] (KAFKA-9974) Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStandbyStore

[ https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9974: Unfortunately this just failed again, at a different place: h3. Stacktrace

Re: [VOTE] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

Thanks, Boyang! +1 (binding) best, Colin On Mon, Jun 15, 2020, at 12:59, Boyang Chen wrote: > Thanks for more feedback Colin! I have addressed them in the KIP. > > Boyang > > On Mon, Jun 15, 2020 at 11:29 AM Colin McCabe wrote: > > > On Fri, Jun 12, 2020, at 15:30, Boyang Chen wrote: > > >

Re: [VOTE] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

Thanks for the KIP Boyang, +1 from me. Guozhang On Wed, Jun 17, 2020 at 1:40 PM Colin McCabe wrote: > Thanks, Boyang! +1 (binding) > > best, > Colin > > On Mon, Jun 15, 2020, at 12:59, Boyang Chen wrote: > > Thanks for more feedback Colin! I have addressed them in the KIP. > > > > Boyang > >

Re: [DISCUSS] KIP-627: Expose Trogdor-specific JMX Metrics for Tasks and Agents

Hi Sam, Thanks for the KIP. Can you add some text clarifying whether a done task continues to be counted in the created-task-count? Looks good aside from that. best, Colin On Wed, Jun 17, 2020, at 12:31, Sam Pal wrote: > Hi all, > > I’d like to start a discussion about adding metrics to

Re: Permission to create KIP

Done. On 6/16/20 11:55 PM, Jiamei Xie wrote: > Hi, > > I'd like permission to create a KIP on the Apache Kafka Wiki. My WikiID is > Jiamei.xie > > > Best wishes > Jiamei Xie > > IMPORTANT NOTICE: The contents of this email and any attachments are > confidential and may also be privileged.

Build failed in Jenkins: kafka-2.6-jdk8 #50

See Changes: [vvcephei] MINOR: Fix flaky HighAvailabilityTaskAssignorIntegrationTest (#8884) [rhauch] KAFKA-10147 MockAdminClient#describeConfigs(Collection) --

[jira] [Resolved] (KAFKA-10155) Flaky Test ReassignPartitionsUnitTest.testModifyBrokerThrottles

[ https://issues.apache.org/jira/browse/KAFKA-10155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10155. - Resolution: Fixed > Flaky Test ReassignPartitionsUnitTest.testModifyBrokerThrottles >

Re: [VOTE] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

+1. Thanks for the KIP and looking forward to the improvement implementation. On Wed, Jun 17, 2020 at 2:24 PM Guozhang Wang wrote: > > Thanks for the KIP Boyang, +1 from me. > > > Guozhang > > On Wed, Jun 17, 2020 at 1:40 PM Colin McCabe wrote: > > > Thanks, Boyang! +1 (binding) > > > > best,

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

See Changes: [github] MINOR: Upgrade jetty to 9.4.27.v20200227 and jersey to 2.31 (#8859) -- [...truncated 6.31 MB...]

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

See Changes: [github] MINOR: clean up unused checkstyle suppressions for Streams (#8861) -- [...truncated 3.17 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Build failed in Jenkins: kafka-trunk-jdk14 #226

See Changes: [github] MINOR: reuse toConfigObject(Map) to generate Config (#8889) -- [...truncated 6.35 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [github] MINOR: reuse toConfigObject(Map) to generate Config (#8889) -- [...truncated 6.35 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Jenkins build is back to normal : kafka-2.6-jdk8 #51

See

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

See Changes: [github] MINOR: reuse toConfigObject(Map) to generate Config (#8889) -- [...truncated 6.30 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Resolved] (KAFKA-10087) Properly throw LogTruncation exception from OffsetForLeaderEpoch future

[ https://issues.apache.org/jira/browse/KAFKA-10087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10087. - Resolution: Fixed > Properly throw LogTruncation exception from OffsetForLeaderEpoch future >

[jira] [Created] (KAFKA-10181) AlterConfig/IncrementalAlterConfig should go to controller

Boyang Chen created KAFKA-10181: --- Summary: AlterConfig/IncrementalAlterConfig should go to controller Key: KAFKA-10181 URL: https://issues.apache.org/jira/browse/KAFKA-10181 Project: Kafka

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

See Changes: [github] MINOR: clean up unused checkstyle suppressions for Streams (#8861) [github] KAFKA-9896: fix flaky StandbyTaskEOSIntegrationTest (#8883) --

Build failed in Jenkins: kafka-2.6-jdk8 #52

See Changes: -- [...truncated 3.14 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldForwardRecordsFromSubtopologyToSubtopology[Eos enabled = false] PASSED

[jira] [Resolved] (KAFKA-10123) Regression resetting offsets in consumer when fetching from old broker

[ https://issues.apache.org/jira/browse/KAFKA-10123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10123. - Resolution: Fixed > Regression resetting offsets in consumer when fetching from old

Jenkins build is back to normal : kafka-trunk-jdk14 #227

See

[jira] [Created] (KAFKA-10182) Change number of partitions of __consumer_offsets

Xu Zhang created KAFKA-10182: Summary: Change number of partitions of __consumer_offsets Key: KAFKA-10182 URL: https://issues.apache.org/jira/browse/KAFKA-10182 Project: Kafka Issue Type:

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

See Changes: [github] KAFKA-9896: fix flaky StandbyTaskEOSIntegrationTest (#8883) [github] KAFKA-10123; Fix incorrect value for AWAIT_RESET#hasPosition (#8841) --