Build failed in Jenkins: kafka-2.3-jdk8 #171

See Changes: [jason] KAFKA-9507; AdminClient should check for missing committed offsets -- [...truncated 3.03 MB...] kafka.controller.PartitionLeaderElectionAlgorithmsTest

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Looking at where the log message comes from: org.apache.kafka.common.config.AbstractConfig#logUnused it seems like maybe the warning just happens when you pass extra configs to a client that it has no knowledge of (and therefore doesn't "use"). I'm now suspicious if Streams is actually sending

Build failed in Jenkins: kafka-2.5-jdk8 #7

See Changes: [cmccabe] KAFKA-9519: Deprecate the --zookeeper flag in ConfigCommand (#8056) [jason] KAFKA-9507; AdminClient should check for missing committed offsets --

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

Hi all, Thanks for the well motivated KIP, Sophie. I had some alternatives in mind, which I won't even bother to relate because I feel like the motivation made a compelling argument for the API as proposed. One very minor point you might as well fix is that the API change is targeted at

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

See Changes: [github] KAFKA-9519: Deprecate the --zookeeper flag in ConfigCommand (#8056) [github] KAFKA-9507; AdminClient should check for missing committed offsets --

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

This situation was discussed at length after a recent talk I gave. This KIP would be a great step towards increased availability and in facilitating lightweight rebalances. anna On Fri, Feb 7, 2020, 9:38 PM Sophie Blee-Goldman wrote: > Hi all, > > In light of some recent and upcoming

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

See Changes: [github] KAFKA-9519: Deprecate the --zookeeper flag in ConfigCommand (#8056) [github] KAFKA-9507; AdminClient should check for missing committed offsets

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

Hi all, In light of some recent and upcoming rebalancing and availability improvements, it seems we have a need for explicitly triggering a consumer group rebalance. Therefore I'd like to propose adding a new rejoinGroup()method to the Consumer client (better method name suggestions are very

[jira] [Created] (KAFKA-9526) Augment topology description with serdes

Guozhang Wang created KAFKA-9526: Summary: Augment topology description with serdes Key: KAFKA-9526 URL: https://issues.apache.org/jira/browse/KAFKA-9526 Project: Kafka Issue Type:

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

See Changes: [github] HOTFIX: Fix two test failures in JDK11 (#8063) [github] KAFKA-9509; Fixing flakiness of -- [...truncated 5.72 MB...]

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

See Changes: [github] HOTFIX: Fix two test failures in JDK11 (#8063) [github] KAFKA-9509; Fixing flakiness of -- [...truncated 2.84 MB...]

Build failed in Jenkins: kafka-2.5-jdk8 #6

See Changes: [jason] KAFKA-9509; Fixing flakiness of -- [...truncated 2.85 MB...] org.apache.kafka.streams.TestTopicsTest > testNonUsedOutputTopic PASSED

[jira] [Resolved] (KAFKA-9507) AdminClient should check for missing committed offsets

[ https://issues.apache.org/jira/browse/KAFKA-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9507. Fix Version/s: 2.4.1 2.3.2 2.5.0 Resolution:

Re: [DISCUSS] KIP-544: Make metrics exposed via JMX configurable

Based on PR feedback I've updated the KIP to align the configs between clients and brokers. Broker configs now start with "metrics.xxx" instead of "kafka.metrics.xxx", in line with clients configs. This is also more consistent with newer broker configs. On Fri, Nov 8, 2019 at 12:23 PM Alexandre

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

See Changes: [github] DOCS - clarify transactionalID and idempotent behavior (#7821) -- [...truncated 2.85 MB...]

[jira] [Created] (KAFKA-9525) Allow explicit rebalance triggering on the Consumer

Sophie Blee-Goldman created KAFKA-9525: -- Summary: Allow explicit rebalance triggering on the Consumer Key: KAFKA-9525 URL: https://issues.apache.org/jira/browse/KAFKA-9525 Project: Kafka

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

See Changes: [github] DOCS - clarify transactionalID and idempotent behavior (#7821) -- [...truncated 2.83 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

[jira] [Created] (KAFKA-9524) Default window retention does not consider grace period

Michael Bingham created KAFKA-9524: -- Summary: Default window retention does not consider grace period Key: KAFKA-9524 URL: https://issues.apache.org/jira/browse/KAFKA-9524 Project: Kafka

[jira] [Created] (KAFKA-9523) Reduce flakiness of BranchedMultiLevelRepartitionConnectedTopologyTest

Boyang Chen created KAFKA-9523: -- Summary: Reduce flakiness of BranchedMultiLevelRepartitionConnectedTopologyTest Key: KAFKA-9523 URL: https://issues.apache.org/jira/browse/KAFKA-9523 Project: Kafka

[jira] [Resolved] (KAFKA-9248) Foreign key join does not pickup default serdes and dies with NPE

[ https://issues.apache.org/jira/browse/KAFKA-9248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9248. Resolution: Duplicate Agreed. Closing this ticket as duplicate. > Foreign key join does

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Ah, got it! I am indeed curious why they do this :) Maybe John can shed more light. But if we can't find a better fix, perhaps the nice thing to do is really a separate logger, so users who are not worried about shooting themselves in the foot can make those warnings go away. Gwen Shapira

[jira] [Resolved] (KAFKA-9177) Pause completed partitions on restore consumer

[ https://issues.apache.org/jira/browse/KAFKA-9177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9177. -- Fix Version/s: 2.6.0 Assignee: Guozhang Wang Resolution: Fixed As part of

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

See Changes: [github] HOTFIX: Fix spotsbug failure in Kafka examples (#8051) [github] MINOR: Add timer for update limit offsets (#8047) [github] MINOR: further InternalTopologyBuilder cleanup (#8046)

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

See Changes: [github] HOTFIX: Fix spotsbug failure in Kafka examples (#8051) [github] MINOR: Add timer for update limit offsets (#8047) [github] MINOR: further InternalTopologyBuilder cleanup (#8046)

Re: [DISCUSS] KIP-552: Add interface to handle unused config

Hi Gwen Kafka Streams is not a third party library and produces a lot of these warnings, e.g. *The configuration 'main.consumer.max.poll.records' was supplied but isn't a known config.* *The configuration 'admin.retries' was supplied but isn't a known config.* and various others if you try to

[jira] [Created] (KAFKA-9522) kafka-connect failed when the topic can not be accessed

Deblock created KAFKA-9522: -- Summary: kafka-connect failed when the topic can not be accessed Key: KAFKA-9522 URL: https://issues.apache.org/jira/browse/KAFKA-9522 Project: Kafka Issue Type: