Re: [VOTE] KIP-900: KRaft kafka-storage.sh API additions to support SCRAM for Kafka Brokers

+1 (binding) Thanks for the KIP. On Wed, Feb 22, 2023 at 3:48 AM José Armando García Sancio wrote: > > LGTM Proven. Thanks for the improvements. +1 (binding) > > -- > -José

Re: [VOTE] KIP-641 An new java interface to replace 'kafka.common.MessageReader'

+1 from me. Thank you Luke On Sat, Feb 25, 2023 at 8:39 AM Chia-Ping Tsai wrote: > Dear all, > > All comments are addressed , and so please take look at this KIP. It needs > vote and love :) > > thanks.

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1619

See Changes: -- [...truncated 446535 lines...] [2023-02-25T04:03:03.432Z] Gradle Test Run :core:integrationTest > Gradle Test Executor 173 > UpdateFeaturesTest >

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #1618

See

[jira] [Created] (KAFKA-14762) Remove 0_8_2_LATEST from rolling upgrade system test

Greg Harris created KAFKA-14762: --- Summary: Remove 0_8_2_LATEST from rolling upgrade system test Key: KAFKA-14762 URL: https://issues.apache.org/jira/browse/KAFKA-14762 Project: Kafka Issue

RE: [VOTE] KIP-641 An new java interface to replace 'kafka.common.MessageReader'

Dear all, All comments are addressed , and so please take look at this KIP. It needs vote and love :) thanks.

[jira] [Resolved] (KAFKA-14685) TierStateMachine interface for building remote aux log

[ https://issues.apache.org/jira/browse/KAFKA-14685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-14685. - Fix Version/s: 3.5.0 Resolution: Fixed merged the PR to trunk. > TierStateMachine interface for

[jira] [Created] (KAFKA-14761) Integration Tests for the New Consumer Implementation

Philip Nee created KAFKA-14761: -- Summary: Integration Tests for the New Consumer Implementation Key: KAFKA-14761 URL: https://issues.apache.org/jira/browse/KAFKA-14761 Project: Kafka Issue

[jira] [Created] (KAFKA-14760) Move ThroughputThrottler, break connect-runtime dependency on tools

Greg Harris created KAFKA-14760: --- Summary: Move ThroughputThrottler, break connect-runtime dependency on tools Key: KAFKA-14760 URL: https://issues.apache.org/jira/browse/KAFKA-14760 Project: Kafka

Re: [DISCUSS] KIP-858: Handle JBOD broker disk failure in KRaft

Hi all, I’ve had to step away from work for personal reasons for a couple of months – until mid April 2023. I don’t think I’ll be able to continue to address feedback or update this KIP before then. -- Igor

[jira] [Created] (KAFKA-14759) Move test-only connectors from connect-runtime to test-specific module

Greg Harris created KAFKA-14759: --- Summary: Move test-only connectors from connect-runtime to test-specific module Key: KAFKA-14759 URL: https://issues.apache.org/jira/browse/KAFKA-14759 Project: Kafka

Re: [DISCUSS] KIP-909: Allow clients to rebootstrap DNS lookup failure

Hey Chris, Thanks for the quick response, and I apologize for the unclear wording there, I guess "DNS lookup" would be a more appropriate wording here. So what I meant there was, to delegate the DNS lookup in the constructor to the network client poll, and it will happen on the very first poll.

[jira] [Resolved] (KAFKA-14540) DataOutputStreamWritable#writeByteBuffer writes the wrong portion of the parameterized buffer

[ https://issues.apache.org/jira/browse/KAFKA-14540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Marshall resolved KAFKA-14540. -- Resolution: Fixed Fixed by https://github.com/apache/kafka/pull/13032 >

Re: [DISCUSS] KIP-909: Allow clients to rebootstrap DNS lookup failure

Hi Philip, Thanks for the KIP! QQ: In the "Proposed Changes" section, the KIP states that "Bootstrapping should now occur in the poll method before attempting to update the metadata. This includes resolving the addresses and bootstrapping the metadata.". By "bootstrapping the metadata" do we

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1617

See Changes: -- [...truncated 447526 lines...] [2023-02-24T21:08:18.500Z] [2023-02-24T21:08:18.500Z] Gradle Test Run :core:integrationTest > Gradle Test Executor 173 >

[jira] [Resolved] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4106. Resolution: Fixed > Consumer / add configure method to PartitionAssignor interface >

[jira] [Resolved] (KAFKA-8177) Allow for separate connect instances to have sink connectors with the same name

[ https://issues.apache.org/jira/browse/KAFKA-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8177. Resolution: Fixed > Allow for separate connect instances to have sink connectors with the

[jira] [Reopened] (KAFKA-8177) Allow for separate connect instances to have sink connectors with the same name

[ https://issues.apache.org/jira/browse/KAFKA-8177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8177: > Allow for separate connect instances to have sink connectors with the same > name >

[jira] [Resolved] (KAFKA-5452) Aggressive log compaction ratio appears to have no negative effect on log-compacted topics

[ https://issues.apache.org/jira/browse/KAFKA-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5452. Resolution: Fixed > Aggressive log compaction ratio appears to have no negative effect on

[jira] [Reopened] (KAFKA-4106) Consumer / add configure method to PartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-4106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4106: > Consumer / add configure method to PartitionAssignor interface >

[jira] [Reopened] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3117: > Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance >

[jira] [Resolved] (KAFKA-6014) new consumer mirror maker halts after committing offsets to a deleted topic

[ https://issues.apache.org/jira/browse/KAFKA-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6014. Resolution: Fixed > new consumer mirror maker halts after committing offsets to a deleted

[jira] [Reopened] (KAFKA-4187) Adding a flag to prefix topics with mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-4187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4187: > Adding a flag to prefix topics with mirror maker >

[jira] [Resolved] (KAFKA-4187) Adding a flag to prefix topics with mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-4187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4187. Resolution: Fixed > Adding a flag to prefix topics with mirror maker >

[jira] [Resolved] (KAFKA-3117) Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-3117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3117. Resolution: Fixed > Fail test at: PlaintextConsumerTest. testAutoCommitOnRebalance >

[jira] [Reopened] (KAFKA-5452) Aggressive log compaction ratio appears to have no negative effect on log-compacted topics

[ https://issues.apache.org/jira/browse/KAFKA-5452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5452: > Aggressive log compaction ratio appears to have no negative effect on > log-compacted

[jira] [Resolved] (KAFKA-949) Integrate kafka into YARN

[ https://issues.apache.org/jira/browse/KAFKA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-949. --- Resolution: Fixed > Integrate kafka into YARN > - > >

[jira] [Reopened] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3410: > Unclean leader election and "Halting because log truncation is not allowed" >

[jira] [Resolved] (KAFKA-8622) Snappy Compression Not Working

[ https://issues.apache.org/jira/browse/KAFKA-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8622. Resolution: Fixed > Snappy Compression Not Working > -- > >

[jira] [Reopened] (KAFKA-6014) new consumer mirror maker halts after committing offsets to a deleted topic

[ https://issues.apache.org/jira/browse/KAFKA-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-6014: > new consumer mirror maker halts after committing offsets to a deleted topic >

[jira] [Resolved] (KAFKA-5734) Heap (Old generation space) gradually increase

[ https://issues.apache.org/jira/browse/KAFKA-5734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5734. Resolution: Fixed > Heap (Old generation space) gradually increase >

[jira] [Reopened] (KAFKA-5734) Heap (Old generation space) gradually increase

[ https://issues.apache.org/jira/browse/KAFKA-5734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-5734: > Heap (Old generation space) gradually increase >

[jira] [Reopened] (KAFKA-949) Integrate kafka into YARN

[ https://issues.apache.org/jira/browse/KAFKA-949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-949: --- > Integrate kafka into YARN > - > > Key: KAFKA-949 >

[jira] [Reopened] (KAFKA-8255) Replica fetcher thread exits with OffsetOutOfRangeException

[ https://issues.apache.org/jira/browse/KAFKA-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8255: > Replica fetcher thread exits with OffsetOutOfRangeException >

[jira] [Resolved] (KAFKA-3410) Unclean leader election and "Halting because log truncation is not allowed"

[ https://issues.apache.org/jira/browse/KAFKA-3410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3410. Resolution: Fixed > Unclean leader election and "Halting because log truncation is not

[jira] [Resolved] (KAFKA-7698) Kafka Broker fail to start: ProducerFencedException thrown from producerstatemanager.scala!checkProducerEpoch

[ https://issues.apache.org/jira/browse/KAFKA-7698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7698. Resolution: Fixed > Kafka Broker fail to start: ProducerFencedException thrown from >

[jira] [Resolved] (KAFKA-8255) Replica fetcher thread exits with OffsetOutOfRangeException

[ https://issues.apache.org/jira/browse/KAFKA-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8255. Resolution: Fixed > Replica fetcher thread exits with OffsetOutOfRangeException >

[jira] [Reopened] (KAFKA-7698) Kafka Broker fail to start: ProducerFencedException thrown from producerstatemanager.scala!checkProducerEpoch

[ https://issues.apache.org/jira/browse/KAFKA-7698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-7698: > Kafka Broker fail to start: ProducerFencedException thrown from >

[jira] [Reopened] (KAFKA-8622) Snappy Compression Not Working

[ https://issues.apache.org/jira/browse/KAFKA-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8622: > Snappy Compression Not Working > -- > > Key:

[jira] [Resolved] (KAFKA-12563) Something wrong with MM2 metrics

[ https://issues.apache.org/jira/browse/KAFKA-12563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12563. - Resolution: Fixed > Something wrong with MM2 metrics >

[jira] [Reopened] (KAFKA-12563) Something wrong with MM2 metrics

[ https://issues.apache.org/jira/browse/KAFKA-12563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-12563: - > Something wrong with MM2 metrics > > >

[jira] [Reopened] (KAFKA-14398) Update EndToEndAuthorizerTest.scala to test with ZK and KRAFT quorum servers

[ https://issues.apache.org/jira/browse/KAFKA-14398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-14398: - > Update EndToEndAuthorizerTest.scala to test with ZK and KRAFT quorum servers >

[jira] [Resolved] (KAFKA-13372) failed authentication due to: SSL handshake failed

[ https://issues.apache.org/jira/browse/KAFKA-13372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13372. - Resolution: Fixed > failed authentication due to: SSL handshake failed >

[jira] [Reopened] (KAFKA-10352) Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-checkpoint (kafka.server.LogDirFailureChannel)

[ https://issues.apache.org/jira/browse/KAFKA-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-10352: - > Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-checkpoint >

[jira] [Resolved] (KAFKA-4329) The order of the parameters for creating the ZkUtils object is reversed

[ https://issues.apache.org/jira/browse/KAFKA-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4329. Resolution: Fixed > The order of the parameters for creating the ZkUtils object is

[jira] [Reopened] (KAFKA-13372) failed authentication due to: SSL handshake failed

[ https://issues.apache.org/jira/browse/KAFKA-13372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-13372: - > failed authentication due to: SSL handshake failed >

[jira] [Resolved] (KAFKA-14398) Update EndToEndAuthorizerTest.scala to test with ZK and KRAFT quorum servers

[ https://issues.apache.org/jira/browse/KAFKA-14398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14398. - Resolution: Fixed > Update EndToEndAuthorizerTest.scala to test with ZK and KRAFT

[jira] [Reopened] (KAFKA-4329) The order of the parameters for creating the ZkUtils object is reversed

[ https://issues.apache.org/jira/browse/KAFKA-4329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4329: > The order of the parameters for creating the ZkUtils object is reversed >

[jira] [Reopened] (KAFKA-10704) Mirror maker with TLS at target

[ https://issues.apache.org/jira/browse/KAFKA-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-10704: - > Mirror maker with TLS at target > --- > >

[jira] [Resolved] (KAFKA-10704) Mirror maker with TLS at target

[ https://issues.apache.org/jira/browse/KAFKA-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10704. - Resolution: Fixed > Mirror maker with TLS at target > --- >

[jira] [Resolved] (KAFKA-10352) Error while reading checkpoint file /tmp/kafka-logs/cleaner-offset-checkpoint (kafka.server.LogDirFailureChannel)

[ https://issues.apache.org/jira/browse/KAFKA-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10352. - Resolution: Fixed > Error while reading checkpoint file

[jira] [Created] (KAFKA-14758) Extract inner classes from Fetcher for reuse in refactoring

Kirk True created KAFKA-14758: - Summary: Extract inner classes from Fetcher for reuse in refactoring Key: KAFKA-14758 URL: https://issues.apache.org/jira/browse/KAFKA-14758 Project: Kafka Issue

[jira] [Resolved] (KAFKA-14717) KafkaStreams can' get running if the rebalance happens before StreamThread gets shutdown completely

[ https://issues.apache.org/jira/browse/KAFKA-14717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14717. - Resolution: Fixed > KafkaStreams can' get running if the rebalance happens before

[jira] [Resolved] (KAFKA-4706) Unify StreamsKafkaClient instances

[ https://issues.apache.org/jira/browse/KAFKA-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4706. Resolution: Fixed > Unify StreamsKafkaClient instances >

[jira] [Reopened] (KAFKA-13599) Upgrade RocksDB to 6.27.3

[ https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-13599: - > Upgrade RocksDB to 6.27.3 > - > > Key:

[jira] [Resolved] (KAFKA-14442) GlobalKTable restoration waits requestTimeout during application restart

[ https://issues.apache.org/jira/browse/KAFKA-14442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-14442. - Resolution: Fixed > GlobalKTable restoration waits requestTimeout during application

[jira] [Reopened] (KAFKA-3576) Unify KStream and KTable API

[ https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-3576: > Unify KStream and KTable API > > > Key:

[jira] [Reopened] (KAFKA-4706) Unify StreamsKafkaClient instances

[ https://issues.apache.org/jira/browse/KAFKA-4706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4706: > Unify StreamsKafkaClient instances > -- > >

[jira] [Resolved] (KAFKA-3576) Unify KStream and KTable API

[ https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-3576. Resolution: Fixed > Unify KStream and KTable API > > >

[jira] [Resolved] (KAFKA-13599) Upgrade RocksDB to 6.27.3

[ https://issues.apache.org/jira/browse/KAFKA-13599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-13599. - Resolution: Fixed > Upgrade RocksDB to 6.27.3 > - > >

[jira] [Resolved] (KAFKA-9250) Kafka streams stuck in rebalancing state after UnknownHostException

[ https://issues.apache.org/jira/browse/KAFKA-9250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9250. Resolution: Fixed > Kafka streams stuck in rebalancing state after UnknownHostException >

[jira] [Reopened] (KAFKA-14442) GlobalKTable restoration waits requestTimeout during application restart

[ https://issues.apache.org/jira/browse/KAFKA-14442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-14442: - > GlobalKTable restoration waits requestTimeout during application restart >

[jira] [Reopened] (KAFKA-9250) Kafka streams stuck in rebalancing state after UnknownHostException

[ https://issues.apache.org/jira/browse/KAFKA-9250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9250: > Kafka streams stuck in rebalancing state after UnknownHostException >

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1616

See Changes: -- [...truncated 447279 lines...] [2023-02-24T17:31:26.397Z] [2023-02-24T17:31:26.397Z] Gradle Test Run :core:integrationTest > Gradle Test Executor 173 >

[VOTE] KIP-907: Add Boolean Serde to public interface

Hi Everyone,  I'd like to call for a vote on KIP-907, which proposes new public classes to the package org.apache.kafka.common.serialization: - BooleanSerde - BooleanSerializer - BooleanDeserializerKIP:lists.apache.org- Jakub

[GitHub] [kafka-site] KomaBeyond opened a new pull request, #494: KAFKA-14751: Official website CONTACT page IRC channel link change

KomaBeyond opened a new pull request, #494: URL: https://github.com/apache/kafka-site/pull/494 "chat.freenode.net" this link should be change to "webchat.freenode.net", since the previous link currently cat not connected. -- This is an automated message from the Apache Git Service. To