jira  

Messages by Thread

• [PR] KSTREAMS-8781: Add back `rack.aware.assignment.tags` config [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20435) Move LogManagerTest to storage module Mickael Maison (Jira)
• [jira] [Created] (KAFKA-20552) Support log segments larger than 2 GB Haifeng Chen (Jira)
• [jira] [Resolved] (KAFKA-19009) Move MetadataCacheTest to metadata module Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20546) Lazily call generateNewClientId when handling GetTelemetrySubscriptionsRequest Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-15768) StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult Bill Bejeck (Jira)
• [jira] [Updated] (KAFKA-15768) StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult Bill Bejeck (Jira)
• [jira] [Resolved] (KAFKA-18563) move RaftClientTestContext xyzRpcVersion methods into RaftProtocol Chia-Ping Tsai (Jira)
• [PR] initial config [kafka] via GitHub
• [jira] [Commented] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics RITIK KUMAR JAISWAL (Jira)
• [jira] [Resolved] (KAFKA-18031) Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt Lianet Magrans (Jira)
• [PR] Test [kafka] via GitHub
  • Re: [PR] Test [kafka] via GitHub
• [jira] [Resolved] (KAFKA-17999) Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota Mickael Maison (Jira)
• [PR] KAFKA-20551: Remove unnecessary generics from TxnOffsetCommitResponse, OffsetCommitResponse, and OffsetDeleteResponse [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20508) Do not log/throw error/exception for corrupted tasks due to compacted changelog topic Kartikay Dubey (Jira)
• [PR] KAFKA-20549: Share group DLQ manager implementation. Skeleton classes [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20549: Share group DLQ manager implementation. Skeleton classes [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20549: Share group DLQ manager implementation. Skeleton classes [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20549: Share group DLQ manager implementation. Skeleton classes [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20549: Share group DLQ manager implementation. Skeleton classes [1/N] [kafka] via GitHub
  • Re: [PR] KAFKA-20549: Share group DLQ manager implementation. Skeleton classes [1/N] [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20551) Remove unnecessary generics from TxnOffsetCommitResponse, OffsetCommitResponse, and OffsetDeleteResponse Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-20551) Remove unnecessary generics from TxnOffsetCommitResponse, OffsetCommitResponse, and OffsetDeleteResponse Chia-Ping Tsai (Jira)
• [PR] MINOR: Fix misleading log message when lastOffset < firstOffset in SharePartition [kafka] via GitHub
• Re: [PR] MINOR: refactor AbstractSegmentsTests to reduce redundancies [kafka] via GitHub
  • Re: [PR] MINOR: refactor AbstractSegmentsTests to reduce redundancies [kafka] via GitHub
• [PR] KAFKA-20550: Rename OffsetsUtils to GroupOffsetsResetter [kafka] via GitHub
• Re: [PR] KAFKA-7138: Add DLQ name and replication factor to Connect configuration [kafka] via GitHub
• [PR] KAFKA-20546: Lazily call generateNewClientId when handling GetTelemetrySubscriptionsRequest [kafka] via GitHub
  • Re: [PR] KAFKA-20546: Lazily call generateNewClientId when handling GetTelemetrySubscriptionsRequest [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20349) Upgrade to ZooKeeper 3.8.6 - fix CVE-2026-24308 Ming-Yen Chung (Jira)
• [jira] [Resolved] (KAFKA-17789) State updater stuck when starting with empty state folder Nikita Shupletsov (Jira)
• [jira] [Resolved] (KAFKA-14192) Move registering and unregistering changelogs to state updater Nikita Shupletsov (Jira)
• [PR] KAFKA-20444: [1/N] Add TxnOffsetCommit v6 schema (KIP-1319) [kafka] via GitHub
  • Re: [PR] KAFKA-20444: [1/N] Add TxnOffsetCommit v6 schema (KIP-1319) [kafka] via GitHub
• [jira] [Updated] (KAFKA-20320) Build Kafka CLI tool to decode Protobuf messages using local proto definitions RITIK KUMAR JAISWAL (Jira)
• [jira] [Resolved] (KAFKA-13499) Avoid restoring outdated records Ziyun Fu (Jira)
• [jira] [Commented] (KAFKA-19148) Potential Unclean Leader Election in KRaft Despite unclean.leader.election.enable=false Pavel Cermak (Jira)
• [jira] [Resolved] (KAFKA-20441) Follow ups for KIP-1066 Mickael Maison (Jira)
• [jira] [Commented] (KAFKA-18389) Do not lose votedKey on transition to LeaderState Yunseop Eom (Jira)
• [jira] [Assigned] (KAFKA-20550) Rename OffsetsUtils to OffsetManager (or OffsetResetService) majialong (Jira)
• [jira] [Created] (KAFKA-20550) Rename OffsetsUtils to OffsetManager (or OffsetResetService) Chia-Ping Tsai (Jira)
• [jira] [Comment Edited] (KAFKA-20170) Support topology updates for streams groups without requiring a new group sanghyeok An (Jira)
• [jira] [Assigned] (KAFKA-20223) Extended I/O Metrics Collection Sahil Devgon (Jira)
• Re: [PR] KAFKA-20167 Introduce CloseOptions.DEFAULT for Kafka Streams [kafka] via GitHub
• [jira] [Commented] (KAFKA-19853) Transaction Failure when StreamThread blocks on StateUpdater during onAssignment() Lucas Brutschy (Jira)
• [jira] [Resolved] (KAFKA-20415) Dynamic config for enabling dlq Sushant Mahajan (Jira)
• [jira] [Resolved] (KAFKA-20410) Add DLQ configuration parameters as defined in the KIP Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-20549) Implementation of Share Group DLQ Manager Sushant Mahajan (Jira)
• [PR] KAFKA-20114: Fix producer ID retry backoff race [kafka] via GitHub
  • Re: [PR] KAFKA-20114: Fix producer ID retry backoff race [kafka] via GitHub
  • Re: [PR] KAFKA-20114: Fix producer ID retry backoff race [kafka] via GitHub
  • Re: [PR] KAFKA-20114: Fix producer ID retry backoff race [kafka] via GitHub
  • Re: [PR] KAFKA-20114: Fix producer ID retry backoff race [kafka] via GitHub
• Re: [PR] KAFKA-19925: Fix transaction timeout handling during broker upgrades [kafka] via GitHub
  • Re: [PR] KAFKA-19925: Fix transaction timeout handling during broker upgrades [kafka] via GitHub
• Re: [PR] Invoke OffsetCommitCallback immediately on commit failure [kafka] via GitHub
• Re: [PR] KAFKA-10549: Add topic ID support to OffsetForLeader - ServerAndProtocol (3/N) [kafka] via GitHub
  • Re: [PR] KAFKA-10549: Add topic ID support to OffsetForLeader - ServerAndProtocol (3/N) [kafka] via GitHub
• [PR] KAFKA-18389: Preserve votedKey when transitioning to leader state [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20071) Fix flaky ProducerIdManagerTest#testRetryBackoff... sanghyeok An (Jira)
• [jira] [Commented] (KAFKA-17164) Consider to enforce application.server <server>:<port> format at config level sanghyeok An (Jira)
• [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka] via GitHub
  • Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka] via GitHub
  • Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka] via GitHub
  • Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka] via GitHub
  • Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka] via GitHub
  • Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka] via GitHub
  • Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka] via GitHub
  • Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka] via GitHub
  • Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka] via GitHub
  • Re: [PR] KAFKA-17164: Enforce 'application.server' <server>:<port> format at config level. [kafka] via GitHub
• [PR] MINOR: Move TestSslUtils to client test fixtures [kafka] via GitHub
  • Re: [PR] MINOR: Move TestSslUtils to client test fixtures [kafka] via GitHub
  • Re: [PR] MINOR: Move TestSslUtils to client test fixtures [kafka] via GitHub
  • Re: [PR] MINOR: Move TestSslUtils to client test fixtures [kafka] via GitHub
• Re: [PR] KAFKA-14485: Move LogCleaner to storage module [kafka] via GitHub
  • Re: [PR] KAFKA-14485: Move LogCleaner to storage module [kafka] via GitHub
• [jira] [Created] (KAFKA-20548) Client instance ID in all request headers Andrew Schofield (Jira)
• [PR] MINOR: Avoid eager readNextOffset() call in Cleaner.cleanSegments [kafka] via GitHub
  • Re: [PR] MINOR: Avoid eager readNextOffset() call in Cleaner.cleanSegments [kafka] via GitHub
  • Re: [PR] MINOR: Avoid eager readNextOffset() call in Cleaner.cleanSegments [kafka] via GitHub
  • Re: [PR] MINOR: Avoid eager readNextOffset() call in Cleaner.cleanSegments [kafka] via GitHub
• [PR] KAFKA-20535: Improve async consumer CPU usage under low max.poll.records. [kafka] via GitHub
  • Re: [PR] KAFKA-20535: Improve async consumer CPU usage under low max.poll.records. [kafka] via GitHub
  • Re: [PR] KAFKA-20535: Improve async consumer CPU usage under low max.poll.records. [kafka] via GitHub
  • Re: [PR] KAFKA-20535: Improve async consumer CPU usage under low max.poll.records. [kafka] via GitHub
  • Re: [PR] KAFKA-20535: Improve async consumer CPU usage under low max.poll.records. [kafka] via GitHub
• [PR] Caching immutable voterKeys [kafka] via GitHub
• [jira] [Commented] (KAFKA-16642) Update KafkaConsumerTest to show parameters in test lists Jiayao Sun (Jira)
• [jira] [Created] (KAFKA-20547) Streams produces duplicates with EOS_v2 Uladzislau Blok (Jira)
• [jira] [Updated] (KAFKA-20547) Streams produces duplicates with EOS_v2 Uladzislau Blok (Jira)
  • [jira] [Updated] (KAFKA-20547) Streams produces duplicates with EOS_v2 Uladzislau Blok (Jira)
• [jira] [Commented] (KAFKA-19866) Support transactional producer in console producer Ming-Yen Chung (Jira)
• [jira] [Commented] (KAFKA-20545) Flaky tests in MirrorConnectorsIntegrationSSLTest Nilesh Kumar (Jira)
  • [jira] [Commented] (KAFKA-20545) Flaky tests in MirrorConnectorsIntegrationSSLTest Muralidhar Basani (Jira)
• [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] via GitHub
  • Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] via GitHub
  • Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] via GitHub
  • Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] via GitHub
  • Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] via GitHub
  • Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] via GitHub
  • Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] via GitHub
  • Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] via GitHub
  • Re: [PR] KAFKA-20524: CSV reset offset plan for kafka-share-groups.sh [kafka] via GitHub
• [jira] [Commented] (KAFKA-20328) Audit and extend test coverage for all headers-aware APIs Muralidhar Basani (Jira)
• Re: [PR] KAFKA-20328 : streams - Adding missing test files - streams headers [kafka] via GitHub
  • Re: [PR] KAFKA-20328 : streams - Adding missing test files - streams headers [kafka] via GitHub
• [PR] KAFKA-20328 : Headers-aware api test coverage [kafka] via GitHub
  • Re: [PR] KAFKA-20328 : Part 1 - headers-aware api test coverage [kafka] via GitHub
• [jira] [Created] (KAFKA-20546) Lazily call generateNewClientId when handling GetTelemetrySubscriptionsRequest Chia-Ping Tsai (Jira)
• [jira] [Assigned] (KAFKA-20546) Lazily call generateNewClientId when handling GetTelemetrySubscriptionsRequest Chia-Ping Tsai (Jira)
  • [jira] [Assigned] (KAFKA-20546) Lazily call generateNewClientId when handling GetTelemetrySubscriptionsRequest Bolin Lin (Jira)
• [PR] MINOR: Add tests for RaftVoterEndpoint [kafka] via GitHub
  • Re: [PR] MINOR: Add tests for RaftVoterEndpoint [kafka] via GitHub
  • Re: [PR] MINOR: Add tests for RaftVoterEndpoint [kafka] via GitHub
  • Re: [PR] MINOR: Add tests for RaftVoterEndpoint [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20092) Dependencies version updates (for Gradle buildscript and project) Jira
• [PR] MINOR: bouncycastle upgrade 1.83 -->> 1.84 (in order to prevent multiple vulnerabilities) [kafka] via GitHub
  • Re: [PR] MINOR: bouncycastle upgrade 1.83 -->> 1.84 (in order to prevent multiple vulnerabilities) [kafka] via GitHub
  • Re: [PR] MINOR: bouncycastle upgrade 1.83 -->> 1.84 (in order to prevent multiple vulnerabilities) [kafka] via GitHub
  • Re: [PR] MINOR: bouncycastle upgrade 1.83 -->> 1.84 (in order to prevent multiple vulnerabilities) [kafka] via GitHub
  • Re: [PR] MINOR: bouncycastle upgrade 1.83 -->> 1.84 (in order to prevent multiple vulnerabilities) [kafka] via GitHub
• [jira] [Updated] (KAFKA-20082) Hide record implementation from user Uladzislau Blok (Jira)
• [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
  • Re: [PR] MINOR: extract TestSslUtils to new test-common-base [kafka] via GitHub
• Re: [PR] Add a SelectorProvider that reuses custom provider implementations. [kafka] via GitHub
• [jira] [Commented] (KAFKA-20265) Add canonical URL tags to Kafka Javadoc pages to point search engines to suggest latest stable version ASF GitHub Bot (Jira)
• [jira] [Resolved] (KAFKA-19700) Fix flaky DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() Matthias J. Sax (Jira)
• [jira] [Resolved] (KAFKA-19701) Mark DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() as flaky Matthias J. Sax (Jira)
• [jira] [Assigned] (KAFKA-19700) Fix flaky DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() Matthias J. Sax (Jira)
• [PR] MINOR: Switched RecordAccumulator.append from ByteBuffer to ByteBufferOutputStream. [kafka] via GitHub
• [jira] [Resolved] (KAFKA-13022) Optimize ClientQuotasImage#describe Chia-Ping Tsai (Jira)
• [PR] KAFKA-20395: Support unregistering controllers [kafka] via GitHub
• [jira] [Commented] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment Lianet Magrans (Jira)
  • [jira] [Commented] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment Nilesh Kumar (Jira)
• [PR] Kafka 19381 add config key builder [kafka] via GitHub
• Re: [PR] KAFKA-19381: add ConfigDef.ConfigKey.Builder [kafka] via GitHub
• [PR] KAFKA-10369: Add deduplication operator to Streams DSL (KIP-655) [kafka] via GitHub
  • Re: [PR] KAFKA-10369: Add deduplication operator to Streams DSL (KIP-655) [kafka] via GitHub
• [jira] [Updated] (KAFKA-10369) Add deduplicate operation in KStream Ayoub Omari (Jira)
  • [jira] [Updated] (KAFKA-10369) Add deduplicate operation in KStream Ayoub Omari (Jira)
  • [jira] [Updated] (KAFKA-10369) Add deduplicate operation in KStream Ayoub Omari (Jira)
• Re: [PR] KAFKA-19685: Add possibility of passing in revoked partitions in task precommit [kafka] via GitHub
  • Re: [PR] KAFKA-19685: Add possibility of passing in revoked partitions in task precommit [kafka] via GitHub
• Re: [PR] Revert "MINOR: Cleanup metadata module" [kafka] via GitHub
  • Re: [PR] Revert "MINOR: Cleanup metadata module" [kafka] via GitHub
• Re: [PR] KAFKA-20329: Test headers dsl.store.format further (2/N) [kafka] via GitHub
• [PR] MINOR: Migrate controllerSocketTimeoutMs from KafkaConfig to AbstractKafkaConfig [kafka] via GitHub
  • Re: [PR] MINOR: Migrate controllerSocketTimeoutMs from KafkaConfig to AbstractKafkaConfig [kafka] via GitHub
  • Re: [PR] MINOR: Migrate controllerSocketTimeoutMs from KafkaConfig to AbstractKafkaConfig [kafka] via GitHub
  • Re: [PR] MINOR: Migrate controllerSocketTimeoutMs from KafkaConfig to AbstractKafkaConfig [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20541) Duplicate generated folder in kafka-site Muralidhar Basani (Jira)
• Re: [PR] KAFKA-20012: Move NodeToControllerChannelManagerImpl to server module [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20536) Empty "Upgrading Servers to 4.1.0" section in upgrade docs across trunk/4.2/4.3 Chia-Ping Tsai (Jira)
• Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
  • Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
  • Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
  • Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
  • Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
  • Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
  • Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
  • Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
  • Re: [PR] KAFKA-18447 Support SASL_SSL protocol with java.security.auth.login.config [kafka] via GitHub
• Re: [PR] KAFKA-19782: Improve perfomance Authorizer.authorizeByResourceType by using Prefix Trie [kafka] via GitHub
  • Re: [PR] KAFKA-19782: Improve perfomance Authorizer.authorizeByResourceType by using Prefix Trie [kafka] via GitHub
• [jira] [Updated] (KAFKA-19785) Two Kafka brokers were not active in 3 node cluster setup Apoorv Mittal (Jira)
  • [jira] [Updated] (KAFKA-19785) Two Kafka brokers were not active in 3 node cluster setup Apoorv Mittal (Jira)
• [jira] [Commented] (KAFKA-20544) Refactor validation of cordoned log dirs in ConfigurationControlManager Chia-Ping Tsai (Jira)
• Re: [PR] MINOR: improve error message on TLS certificate validation failure [kafka] via GitHub
  • Re: [PR] MINOR: improve error message on TLS certificate validation failure [kafka] via GitHub
• Re: [PR] KAFKA-19877: Clarify ByteBuffer position and limit expectations for Deserializer [kafka] via GitHub
• Re: [PR] Add producer metrics for adaptive partitioning [kafka] via GitHub
  • Re: [PR] Add producer metrics for adaptive partitioning [kafka] via GitHub
• Re: [PR] KAFKA-20087: Automate Docker Images creation workflow [kafka] via GitHub
  • Re: [PR] KAFKA-20087: Automate Docker Images creation workflow [kafka] via GitHub
• [jira] [Assigned] (KAFKA-18448) Support SSL protocol with java.security.auth.login.config PoAn Yang (Jira)
• [jira] [Assigned] (KAFKA-10844) groupBy without shuffling Guang Zhao (Jira)
• [jira] [Assigned] (KAFKA-20544) Refactor validation of cordoned log dirs in ConfigurationControlManager TaiJuWu (Jira)
• [PR] KAFKA-20531: ducker-ak: Add --clean-build option to replace REBUILD env var [kafka] via GitHub
• [PR] MINOR: Include numeric bound in group config validation errors [kafka] via GitHub
  • Re: [PR] MINOR: Include numeric bound in group config validation errors [kafka] via GitHub
  • Re: [PR] MINOR: Include numeric bound in group config validation errors [kafka] via GitHub
  • Re: [PR] MINOR: Include numeric bound in group config validation errors [kafka] via GitHub
  • Re: [PR] MINOR: Include numeric bound in group config validation errors [kafka] via GitHub
  • Re: [PR] MINOR: Include numeric bound in group config validation errors [kafka] via GitHub
  • Re: [PR] MINOR: Include numeric bound in group config validation errors [kafka] via GitHub

• Earlier messages