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

See

Build failed in Jenkins: kafka-2.1-jdk8 #266

See Changes: [jason] KAFKA-8104: Consumer cannot rejoin to the group after rebalancing -- [...truncated 2.82 MB...] org.apache.kafka.streams.kstream.internals.SessionWindowe

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

See Changes: [rajinisivaram] KAFKA-9494; Include additional metadata information in DescribeConfig -- [...truncated 6.25 MB...] org.apache.kafka.streams.test.ConsumerRecordF

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

See Changes: [github] KAFKA-8104; Consumer cannot rejoin to the group after rebalancing -- [...truncated 2.83 MB...] kafka.coordinator.group.GroupMetadataManagerTest > test

[jira] [Created] (KAFKA-10072) Kafkaconsumer is configured with different clientid parameters to obtain different results

victor created KAFKA-10072: -- Summary: Kafkaconsumer is configured with different clientid parameters to obtain different results Key: KAFKA-10072 URL: https://issues.apache.org/jira/browse/KAFKA-10072 Projec

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

See Changes: [github] KAFKA-9501: convert between active and standby without closing stores [github] KAFKA-9130; KIP-518 Allow listing consumer groups per state (#8238) [github] KAFKA-10061; Fix flaky ---

Build failed in Jenkins: kafka-2.2-jdk8 #46

See Changes: [github] KAFKA-8104; Consumer cannot rejoin to the group after rebalancing -- [...truncated 1.33 MB...] kafka.utils.CommandLineUtilsTest > testParseEmptyArgWith

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

See Changes: [github] KAFKA-10056; Ensure consumer metadata contains new topics on [github] KAFKA-9501: convert between active and standby without closing stores [github] KAFKA-9130; KIP-518 Allow listing cons

[jira] [Created] (KAFKA-10071) TopicCommand tool should make more efficient metadata calls to Kafka Servers

Vinoth Chandar created KAFKA-10071: -- Summary: TopicCommand tool should make more efficient metadata calls to Kafka Servers Key: KAFKA-10071 URL: https://issues.apache.org/jira/browse/KAFKA-10071 Proj

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

See

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

See

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

See Changes: [rajinisivaram] KAFKA-10056; Ensure consumer metadata contains new topics on -- [...truncated 5.91 MB...] org.apache.kafka.streams.TopologyTestDriverTest > sh

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

See Changes: [rajinisivaram] KAFKA-10056; Ensure consumer metadata contains new topics on -- [...truncated 2.83 MB...] kafka.api.AdminClientIntegrationTest > testCallInFlig

[jira] [Resolved] (KAFKA-9494) Include data type of the config in ConfigEntry

[ https://issues.apache.org/jira/browse/KAFKA-9494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-9494. --- Fix Version/s: 2.6.0 Reviewer: Rajini Sivaram Resolution: Fixed > Include dat

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

See Changes: [github] KAFKA-10056; Ensure consumer metadata contains new topics on [github] KAFKA-9501: convert between active and standby without closing stores -- [...

Re: [DISCUSS] Apache Kafka 2.6.0 release

Hi Randall, We have to remove KIP-584 from the release plan, as this item will not be completed for 2.6 release (although KIP is accepted). We plan to include it in a next release. Cheers, Kowshik On Fri, May 29, 2020 at 11:43 AM Maulin Vasavada wrote: > Hi Randall Hauch > > Can we add KIP-5

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

See Changes: [wangguoz] KAFKA-9501: convert between active and standby without closing stores [jason] KAFKA-9130; KIP-518 Allow listing consumer groups per state (#8238) [jason] KAFKA-10061; Fix flaky

[jira] [Resolved] (KAFKA-10061) Flaky Test `ReassignPartitionsIntegrationTest .testCancellation`

[ https://issues.apache.org/jira/browse/KAFKA-10061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10061. - Fix Version/s: 2.6.0 Resolution: Fixed > Flaky Test `ReassignPartitionsIntegratio

[jira] [Resolved] (KAFKA-9130) Allow listing consumer groups per state

[ https://issues.apache.org/jira/browse/KAFKA-9130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9130. Fix Version/s: 2.6.0 Resolution: Fixed > Allow listing consumer groups per state > -

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

See Changes: [github] KAFKA-10056; Ensure consumer metadata contains new topics on -- [...truncated 3.14 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldI

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

See Changes: [github] MINOR: Log the reason for coordinator discovery failure (#8747) -- [...truncated 8.64 MB...] org.apache.kafka.streams.TopologyTestDriverTest > sho

[jira] [Created] (KAFKA-10070) Parameterize Connect unit tests to remove code duplication

Chris Egerton created KAFKA-10070: - Summary: Parameterize Connect unit tests to remove code duplication Key: KAFKA-10070 URL: https://issues.apache.org/jira/browse/KAFKA-10070 Project: Kafka

Re: [DISCUSS] Apache Kafka 2.6.0 release

Hi Randall Hauch Can we add KIP-519 to 2.6? It was merged to Trunk already in April - https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=128650952. Thanks Maulin On Fri, May 29, 2020 at 11:01 AM Randall Hauch wrote: > Here's an update on the AK 2.6.0 release. > > Code freeze was

Re: [DISCUSS] 2.5.1 Bug Fix Release

Thanks John for managing the release! On Fri, May 29, 2020 at 11:56 AM John Roesler wrote: > Hello all, > > I'd like to volunteer as release manager for the 2.5.1 bugfix release. > > Kafka 2.5.0 was released on 15 April 2020, and 40 issues have been fixed > since then. > > The release plan is do

Re: [DISCUSS] 2.5.1 Bug Fix Release

Thanks for volunteering John, +1. On Fri, May 29, 2020 at 1:58 PM Ismael Juma wrote: > Thanks for volunteering! +1 > > Ismael > > On Fri, May 29, 2020 at 8:56 AM John Roesler wrote: > > > Hello all, > > > > I'd like to volunteer as release manager for the 2.5.1 bugfix release. > > > > Kafka 2.5

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

See

Re: [DISCUSS] Apache Kafka 2.6.0 release

Here's an update on the AK 2.6.0 release. Code freeze was Wednesday, and the release plan [1] has been updated to reflect all of the KIPs that made the release. We've also cut the `2.6` branch that we'll use for the release; see separate email announcing the new branch. The next important date fo

Re: [DISCUSS] 2.5.1 Bug Fix Release

Thanks for volunteering! +1 Ismael On Fri, May 29, 2020 at 8:56 AM John Roesler wrote: > Hello all, > > I'd like to volunteer as release manager for the 2.5.1 bugfix release. > > Kafka 2.5.0 was released on 15 April 2020, and 40 issues have been fixed > since then. > > The release plan is docum

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

See

Jenkins build is back to normal : kafka-2.5-jdk8 #137

See

Re: KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

Hi, David, Anna, Thanks for the response. Sorry for the late reply. 10. Regarding exposing rate or usage as quota. Your argument is that usage is not very accurate anyway and is harder to implement. So, let's just be a bit loose and expose rate. I am sort of neutral on that. (1) It seems to me th

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

See Changes: [vvcephei] MINOR: regression test for task assignor config (#8743) [vvcephei] MINOR: Relax Percentiles test (#8748) -- [...truncated 3.13 MB...] org.apache.kafk

[DISCUSS] 2.5.1 Bug Fix Release

Hello all, I'd like to volunteer as release manager for the 2.5.1 bugfix release. Kafka 2.5.0 was released on 15 April 2020, and 40 issues have been fixed since then. The release plan is documented here: https://cwiki.apache.org/confluence/display/KAFKA/Release+Plan+2.5.1 Thanks, -John

[jira] [Created] (KAFKA-10069) The user-defined "predicate" and "negate" are not removed from Transformation

Chia-Ping Tsai created KAFKA-10069: -- Summary: The user-defined "predicate" and "negate" are not removed from Transformation Key: KAFKA-10069 URL: https://issues.apache.org/jira/browse/KAFKA-10069 Pro

[VOTE] KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

Hi folks, I'd like to start the vote for KIP-599 which proposes a new quota to throttle create topic, create partition, and delete topics operations to protect the Kafka controller: https://cwiki.apache.org/confluence/display/KAFKA/KIP-599%3A+Throttle+Create+Topic%2C+Create+Partition+and+Delete+To

Kafka _Querys

Hi Kafka team, As of now we have successfully implemented kafka for our environment, We stuck up with below questions so please provide assistance and help for below questions. 1) What are the distinct consumer group names currently consuming messages from the same topic 2) Total number of messa

[jira] [Created] (KAFKA-10068) Verify HighAvailabilityTaskAssignor performance with large clusters and topologies

John Roesler created KAFKA-10068: Summary: Verify HighAvailabilityTaskAssignor performance with large clusters and topologies Key: KAFKA-10068 URL: https://issues.apache.org/jira/browse/KAFKA-10068 Pr

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

See Changes: [github] KAFKA-10029; Don't update completedReceives when channels are closed to -- [...truncated 6.28 MB...] org.apache.kafka.streams.internals.KeyValueSto

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

See Changes: [github] KAFKA-10029; Don't update completedReceives when channels are closed to -- [...truncated 3.13 MB...] org.apache.kafka.streams.TopologyTestDriverTest

[jira] [Created] (KAFKA-10067) Provide API to detect cluster nodes version

Yanming Zhou created KAFKA-10067: Summary: Provide API to detect cluster nodes version Key: KAFKA-10067 URL: https://issues.apache.org/jira/browse/KAFKA-10067 Project: Kafka Issue Type: Impro

Re: [Vote] KIP-569: Update DescribeConfigsResponse to include additional metadata information

Based on the PR feedback, I have updated the KIP

回复：回复：回复：回复：回复：回复：回复：[Vote] KIP-571: Add option to force remove members in StreamsResetter

Hi, team I updated the KIP-571 since we took a slightly different implementation in the PR https://github.com/apache/kafka/pull/8589, basically: In RemoveMembersFromConsumerGroupOptions, leveraging empty members rather than introducing a new field to imply the removeAll scenario.

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

Quick update: While implementing the KIP, we made a couple of changes: - Use regular fields instead of flexible fields. We had to bump the protocol version to detect compatibility so flexible fields were not helping much for this low volume API. - If no states are specified in the request, return a

[jira] [Resolved] (KAFKA-10029) Selector.completedReceives should not be modified when channel is closed

[ https://issues.apache.org/jira/browse/KAFKA-10029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-10029. Reviewer: Ismael Juma Resolution: Fixed > Selector.completedReceives should not be m

[jira] [Created] (KAFKA-10066) TopologyTestDriver.createOutputTopic isn't taking record headers into account during deserialization

Stefaan Dutry created KAFKA-10066: - Summary: TopologyTestDriver.createOutputTopic isn't taking record headers into account during deserialization Key: KAFKA-10066 URL: https://issues.apache.org/jira/browse/KAFKA-1

[DISCUSSION] KIP-619: Add internal topic creation support

Hello developers, I’m proposing KIP-619 to add internal topic creation support. Kafka and its upstream applications treat internal topics differently from non-internal topics. For example: • Kafka handles topic creation response errors differently for internal topics • Intern

[jira] [Created] (KAFKA-10065) One of the Kafka broker processes in the cluster suddenly hangs and becomes unresponsive

akihiro kumabe created KAFKA-10065: -- Summary: One of the Kafka broker processes in the cluster suddenly hangs and becomes unresponsive Key: KAFKA-10065 URL: https://issues.apache.org/jira/browse/KAFKA-10065