dev  

Messages by Thread

• [jira] [Created] (KAFKA-19864) Handle TimeoutException from initializeIfNeeded() in StateUpdater Code Shashank (Jira)
• [jira] [Created] (KAFKA-19863) Add documentation on how to implement a custom exception handler Nikita Shupletsov (Jira)
• [jira] [Resolved] (KAFKA-19859) Bug: Start offset moved incorrectly on receiving acknowledgements for offset post LSO movement Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19862) Group coordinator loading may fail when there is concurrent compaction Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-19861) Optimization of the Murmur2 hash computation Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-19843) SharePartition changes to support renew ack. Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-19861) Optimization of the Murmur2 hash computation Otmar Ertl (Jira)
• [jira] [Resolved] (KAFKA-19773) Include push interval in ClientTelemetryReceiver context Mickael Maison (Jira)
• [jira] [Created] (KAFKA-19860) Implement integration tests for share group lag Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-19802) Update ShareGroupCommand to use share partition lag information Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19859) Bug: Start offset moved incorrectly on receiving acknowledgements for offset post LSO movement Abhinav Dixit (Jira)
• [jira] [Resolved] (KAFKA-19799) Introduce deliveryCompleteCount in ReadShareGroupStateSummary Chirag Wadhwa (Jira)
• [jira] [Reopened] (KAFKA-19301) Move PartitionListener, AlterPartitionListener, AssignmentState, PartitionState, and PendingPartitionChange to to server module Chih-Yuan Chien (Jira)
• [jira] [Resolved] (KAFKA-19614) The records appended to the log are illegal because of an incorrect base offset during TestLinearWriteSpeed Chia-Ping Tsai (Jira)
• [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Harish Vishwanath
  • Re: [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Muralidhar Basani
  • Re: [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Harish Vishwanath
  • Re: [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Muralidhar Basani
  • Re: [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Harish Vishwanath
  • Re: [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Muralidhar Basani
  • Re: [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Harish Vishwanath
  • Re: [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Muralidhar Basani via dev
  • Re: [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Harish Vishwanath
  • Re: [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Ashwin via dev
  • Re: [DISCUSS][KIP-1133] Kafka Website Migration to Markdown - Staging Site and Cut-over Plan Muralidhar Basani via dev
• [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Ming-Yen Chung
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Chia-Ping Tsai
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Federico Valeri
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Andrew Schofield
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer 黃竣陽
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer PoAn Yang
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer TaiJu Wu
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Ming-Yen Chung
  • RE: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Hsu Jhen-Yung
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Lianet M.
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Kuan-Po Tseng
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Omnia Ibrahim
  • Re: [VOTE] KIP-1231: Deprecate '--max-partition-memory-bytes' option in ConsoleProducer Kirk True
• [jira] [Resolved] (KAFKA-19797) Implement deliveryCompleteCount in writeShareGroupStateRPC Chirag Wadhwa (Jira)
• [jira] [Resolved] (KAFKA-19798) Persist deliveryCompleteCount in ShareSnapshot and ShareUpdate records Chirag Wadhwa (Jira)
• [DISCUSS] KIP-1137: Standardize Configuration Precedence for Tool Scripts Jhen-Yung Hsu
  • Re: [DISCUSS] KIP-1137: Standardize Configuration Precedence for Tool Scripts Kirk True
  • RE: Re: [DISCUSS] KIP-1137: Standardize Configuration Precedence for Tool Scripts Jhen-Yung Hsu
• [jira] [Reopened] (KAFKA-18471) Race conditions when accessing RecordHeader data Ming-Yen Chung (Jira)
• [jira] [Reopened] (KAFKA-18470) Race conditions when accessing RecordHeader data Ming-Yen Chung (Jira)
• [jira] [Resolved] (KAFKA-18471) Race conditions when accessing RecordHeader data Ming-Yen Chung (Jira)
• [jira] [Resolved] (KAFKA-17284) Disable to create offset topic in setup phase when using `ClusterTestExtensions` Ming-Yen Chung (Jira)
• [jira] [Resolved] (KAFKA-18470) Race conditions when accessing RecordHeader data Ming-Yen Chung (Jira)
  • [jira] [Resolved] (KAFKA-18470) Race conditions when accessing RecordHeader data Ming-Yen Chung (Jira)
• [jira] [Resolved] (KAFKA-17725) RecordHeader key() is not thread safe Ming-Yen Chung (Jira)
• [jira] [Resolved] (KAFKA-19814) Protocol schema and public API changes Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19858) Add configurable min.insync.replicas (default=2) for __remote_log_metadata topic fujian (Jira)
• [jira] [Resolved] (KAFKA-19855) Fix typo in README.md file Chia-Ping Tsai (Jira)
• [PR] Sync latest and multiple improvements [kafka-site] via GitHub
  • Re: [PR] Sync latest and multiple improvements [kafka-site] via GitHub
• [jira] [Created] (KAFKA-19857) CoordinatorExecutorImpl.cancelAll always throws IllegalStateException when there are running tasks Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-12999) NPE when accessing RecordHeader.key() concurrently Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19426) TopicBasedRemoteLogMetadataManager's initial should happen after the broker ready Chia-Ping Tsai (Jira)
• [DISCUSS] KIP-1233: Maximum lengths for resource names and IDs Andrew Schofield
  • Re: [DISCUSS] KIP-1233: Maximum lengths for resource names and IDs Kirk True
  • Re: [DISCUSS] KIP-1233: Maximum lengths for resource names and IDs Andrew Schofield
  • Re: [DISCUSS] KIP-1233: Maximum lengths for resource names and IDs Kirk True
• [jira] [Created] (KAFKA-19856) Stabilize ClientUtilsTest.testParseAndValidateAddressesWithReverseLookup Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19855) Fix typo in README.md file Pawandeep Singh (Jira)
• [jira] [Created] (KAFKA-19854) update the docs of AcknowledgementCommitCallback Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19813) Incorrect jitter value in StreamsGroupHeartbeatRequestManager and AbstractHeartbeatRequestManager Chia-Ping Tsai (Jira)
• RE: Re: [VOTE] 4.1.1 RC2 Colt McNealy
  • RE: [VOTE] 4.1.1 RC2 Maroš Orsák
• [jira] [Created] (KAFKA-19853) StreamThread blocks on StateUpdater during onAssignment() Colt McNealy (Jira)
• [PR] MINOR: Fix the href attribute for the heading Errant Record Reporter in connect.html [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix the href attribute for the heading Errant Record Reporter in connect.html [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix the href attribute for the heading Errant Record Reporter in connect.html [kafka-site] via GitHub
• [jira] [Created] (KAFKA-19852) MetadataShell read 0000-0000.checkpoint will cause infinite loop TaiJuWu (Jira)
• [jira] [Created] (KAFKA-19851) Delete dynamic config that were removed by Kafka Jira
• [jira] [Created] (KAFKA-19850) KRaft voter auto join will add a removed voter immediately Luke Chen (Jira)
• [jira] [Created] (KAFKA-19849) Move ThrottledChannelExpirationTest to server-common module Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19848) Revert KIP-939 API's and Client Code for 4.2 Ritika Reddy (Jira)
• [jira] [Resolved] (KAFKA-19165) PartitionLeaderStrategy has very high error rate during topic initialization Steven Schlansker (Jira)
• [PR] MyLegalSoftware kafka use [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-19606) Anomaly of JMX metrics RequestHandlerAvgIdlePercent in kraft combined mode Jira
• [jira] [Created] (KAFKA-19847) Discuss quorum-related config limitations TaiJuWu (Jira)
• [jira] [Created] (KAFKA-19846) ShareFetch RPC doesn't allow Pranav Rathi (Jira)
• [jira] [Resolved] (KAFKA-19796) Introduce computations for inFlightTerminalRecords Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-19791) Add Idle Thread Ratio Metric to MetadataLoader Jira
• [jira] [Resolved] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky PoAn Yang (Jira)
• [jira] [Resolved] (KAFKA-19820) remove the unnecessary copy from AbstractFetch#fetchablePartitions Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19301) Move PartitionListener, AlterPartitionListener, AssignmentState, PartitionState, and PendingPartitionChange to storage module Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-19845) Share consumer changes to support renew ack. Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-19842) Additional tests in ShareConsumerTest Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-19844) Modification of share fetch to accommodate piggybacked renewals. Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-19843) SharePartition changes to support renew ack. Sushant Mahajan (Jira)
• [jira] [Resolved] (KAFKA-19345) Use ShareFetchUtils mock for DelayedShareFetchTest tests Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-18894) Add support for ConfigProvider Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-19841) Fix the negative remote bytesLag and segmentsLag metric Kamal Chandraprakash (Jira)
• [jira] [Created] (KAFKA-19841) Fix the negative remote bytesLag and segmentsLag metric Kamal Chandraprakash (Jira)
• [DISCUSS] KIP-1220: kafka-broker-api-versions tool support bootstrap controllers TaiJu Wu
  • Re: [DISCUSS] KIP-1220: kafka-broker-api-versions tool support bootstrap controllers TaiJu Wu
  • Re: [DISCUSS] KIP-1220: kafka-broker-api-versions tool support bootstrap controllers Kirk True
  • Re: [DISCUSS] KIP-1220: kafka-broker-api-versions tool support bootstrap controllers TaiJu Wu
  • Re: [DISCUSS] KIP-1220: kafka-broker-api-versions tool support bootstrap controllers Andrew Schofield
  • Re: [DISCUSS] KIP-1220: kafka-broker-api-versions tool support bootstrap controllers TaiJu Wu
• [jira] [Resolved] (KAFKA-19789) Handle situations where broker responses appear logically incorrect Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19840) Flaky test ShareConsumerTest. testShareGroupMaxSizeConfigExceeded Sanskar Jhajharia (Jira)
• [jira] [Resolved] (KAFKA-19824) New ConnectorClientConfigOverridePolicy with allowlist of configurations Mickael Maison (Jira)
• [jira] [Created] (KAFKA-19839) Native-image (dockerimage) does not work with compression.type=zstd Jira
• [PR] Make release dropdown scrollable, committer page layout better [kafka-site] via GitHub
  • Re: [PR] Make release dropdown scrollable, committer page layout better [kafka-site] via GitHub
• [PR] Minor UX improvements [kafka-site] via GitHub
  • Re: [PR] Minor UX improvements [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-19823) PartitionMaxBytesStrategy bug when request bytes is lesser than acquired topic partitions Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-16926) Optimize BeginQuorumEpoch heartbeat Jira
• Add support for configurable target field in TimestampConverter SMT PIATEK Marcin
  • Re: Add support for configurable target field in TimestampConverter SMT Christo Lolov
  • RE: Add support for configurable target field in TimestampConverter SMT PIATEK Marcin
• [jira] [Created] (KAFKA-19838) Follow up for KIP-1217 Mickael Maison (Jira)
• [jira] [Created] (KAFKA-19837) Follow up for KIP-1188 Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-19784) Expose Rack ID in MemberDescription Andrew Schofield (Jira)
• RE: Re: [DISCUSS] Apache Kafka 4.1.1 release Antonio Soldo
  • Re: Re: [DISCUSS] Apache Kafka 4.1.1 release Lianet M.
  • Re: Re: [DISCUSS] Apache Kafka 4.1.1 release Antonio Soldo
• [DISCUSS] KIP-1234: Move and Add Arguments to version-mapping Commands Huang, Chang-Yu
  • Re: [DISCUSS] KIP-1234: Move and Add Arguments to version-mapping Commands Kuan-Po Tseng
  • Re: [DISCUSS] KIP-1234: Move and Add Arguments to version-mapping Commands Huang, Chang-Yu
  • Re: [DISCUSS] KIP-1234: Move and Add Arguments to version-mapping Commands Christo Lolov
  • Re: [DISCUSS] KIP-1234: Move and Add Arguments to version-mapping Commands Huang, Chang-Yu
  • Re: [DISCUSS] KIP-1234: Move and Add Arguments to version-mapping Commands Christo Lolov
  • Re: [DISCUSS] KIP-1234: Move and Add Arguments to version-mapping Commands Huang, Chang-Yu
• [jira] [Resolved] (KAFKA-19836) Decouple ConsumerConfig and ShareConsumerConfig TaiJuWu (Jira)
• [jira] [Created] (KAFKA-19836) Decouple ConsumerConfig and ShareConsumerConfig TaiJuWu (Jira)
• [PR] KAFKA-19835: The Content-Security-Policy header must not be overridden [kafka-site] via GitHub
  • Re: [PR] KAFKA-19835: The Content-Security-Policy header must not be overridden [kafka-site] via GitHub
  • Re: [PR] KAFKA-19835: The Content-Security-Policy header must not be overridden [kafka-site] via GitHub
  • Re: [PR] KAFKA-19835: The Content-Security-Policy header must not be overridden [kafka-site] via GitHub
  • Re: [PR] KAFKA-19835: The Content-Security-Policy header must not be overridden [kafka-site] via GitHub
  • Re: [PR] KAFKA-19835: The Content-Security-Policy header must not be overridden [kafka-site] via GitHub
  • Re: [PR] KAFKA-19835: The Content-Security-Policy header must not be overridden [kafka-site] via GitHub
  • Re: [PR] KAFKA-19835: The Content-Security-Policy header must not be overridden [kafka-site] via GitHub
  • Re: [PR] KAFKA-19835: The Content-Security-Policy header must not be overridden [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-19810) Kafka streams with chained emitStrategy(onWindowClose) example does not work Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-19835) The Content-Security-Policy header must not be overridden Sebb (Jira)
• RE: Re: [VOTE] 4.1.1 RC1 Colt McNealy
• [jira] [Created] (KAFKA-19834) Cleanup suppressions.xml majialong (Jira)
• [jira] [Resolved] (KAFKA-19803) Relax state directory file system restrictions Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-19833) Refactor Nullable Types to Use a Unified Pattern Lan Ding (Jira)
• [VOTE] KIP-1229: Add Idle Thread Ratio Metric to MetadataLoader Mahsa Seifikar
  • Re: [VOTE] KIP-1229: Add Idle Thread Ratio Metric to MetadataLoader Manikumar
  • Re: [VOTE] KIP-1229: Add Idle Thread Ratio Metric to MetadataLoader José Armando García Sancio
  • Re: [VOTE] KIP-1229: Add Idle Thread Ratio Metric to MetadataLoader David Jacot
  • Re: [VOTE] KIP-1229: Add Idle Thread Ratio Metric to MetadataLoader Chia-Ping Tsai
  • Re: [VOTE] KIP-1229: Add Idle Thread Ratio Metric to MetadataLoader Lianet M.
  • Re: [VOTE] KIP-1229: Add Idle Thread Ratio Metric to MetadataLoader Christo Lolov
  • Re: [VOTE] KIP-1229: Add Idle Thread Ratio Metric to MetadataLoader Mahsa Seifikar
  • Re: [VOTE] KIP-1229: Add Idle Thread Ratio Metric to MetadataLoader Mahsa Seifikar
• Maximum size of COMPACT_STRING Jonah Hooper
  • Re: Maximum size of COMPACT_STRING Jun Rao
  • Re: Maximum size of COMPACT_STRING Jonah Hooper
  • Re: Maximum size of COMPACT_STRING Jun Rao
  • Re: Maximum size of COMPACT_STRING José Armando García Sancio
  • Re: Maximum size of COMPACT_STRING Jonah Hooper via dev
• [jira] [Resolved] (KAFKA-19340) Move DelayedRemoteFetch to the storage module Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-19746) Tools | Fix order of arguments to assertEquals in unit test Ksolves India Limited (Jira)
• [jira] [Resolved] (KAFKA-19827) Call acknowledgement commit callback at end of waiting calls Andrew Schofield (Jira)
• [VOTE] KIP-1211: Align the behavior of num.partitions and default.replication.factor for topic creation Kuan-Po Tseng
  • Re: [VOTE] KIP-1211: Align the behavior of num.partitions and default.replication.factor for topic creation Chia-Ping Tsai
  • Re: [VOTE] KIP-1211: Align the behavior of num.partitions and default.replication.factor for topic creation Omnia Ibrahim
• [jira] [Created] (KAFKA-19832) Move ClientOAuthIntegrationTest to clients-integration-tests Kirk True (Jira)
• [jira] [Created] (KAFKA-19831) Failures in the StateUpdater thread may lead to inability to shut down a stream thread Nikita Shupletsov (Jira)
• [jira] [Resolved] (KAFKA-19662) Support resetting offsets in kafka-share-groups.sh for topics which are not currently subscribed Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-19830) Refactor KafkaRaftClient to use event scheduler framework Kevin Wu (Jira)
• [jira] [Resolved] (KAFKA-19255) KRaft request manager should support one in-flight request per request type Kevin Wu (Jira)
• The Future of streams-scala Chia-Ping Tsai
  • Re: The Future of streams-scala Dejan Stojadinović
  • Re: The Future of streams-scala Ismael Juma
  • Re: The Future of streams-scala Matthias J. Sax
  • Re: The Future of streams-scala Jiří Syrový
  • Re: The Future of streams-scala Ismael Juma
  • Re: The Future of streams-scala Chia-Ping Tsai
  • Re: The Future of streams-scala Chia-Ping Tsai
  • Re: The Future of streams-scala Matthias J. Sax
  • Re: The Future of streams-scala PoAn Yang
  • Re: The Future of streams-scala Matthias J. Sax
  • Re: The Future of streams-scala Ismael Juma
• [jira] [Created] (KAFKA-19829) Implement group-level initial rebalance delay travis (Jira)
• [VOTE] KIP-1228: Add Transaction Version to WriteTxnMarkersRequest Ritika Reddy
  • Re: [VOTE] KIP-1228: Add Transaction Version to WriteTxnMarkersRequest Andrew Schofield
  • Re: [VOTE] KIP-1228: Add Transaction Version to WriteTxnMarkersRequest Calvin Liu
  • Re: [VOTE] KIP-1228: Add Transaction Version to WriteTxnMarkersRequest David Jacot
  • Re: [VOTE] KIP-1228: Add Transaction Version to WriteTxnMarkersRequest Justine Olshan
  • Re: [VOTE] KIP-1228: Add Transaction Version to WriteTxnMarkersRequest Ritika Reddy
• [jira] [Created] (KAFKA-19828) Intermittent test failures when using chained emit strategy on window close Greg F (Jira)
• [VOTE] 4.1.1 RC0 Lianet M.
  • Re: [VOTE] 4.1.1 RC0 Chia-Ping Tsai
  • Re: [VOTE] 4.1.1 RC0 Lianet M.
  • [VOTE] 4.1.1 RC1 Lianet M.
  • Re: [VOTE] 4.1.1 RC1 Chia-Ping Tsai
  • Re: [VOTE] 4.1.1 RC1 Lianet M.
  • Re: [VOTE] 4.1.1 RC1 Chia-Ping Tsai
  • [VOTE] 4.1.1 RC2 Lianet M.
  • Re: [VOTE] 4.1.1 RC2 Mickael Maison
  • Re: [VOTE] 4.1.1 RC2 Lianet M.

• Earlier messages
• Later messages