dev  

Messages by Thread

• [jira] [Resolved] (KAFKA-21264) Javadoc output language depends on the build machine's system locale Ken Huang (Jira)
• [jira] [Created] (KAFKA-21263) Missing header-aware store variants for stream-stream outer joins Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-21271) Use RebalanceConsumer in WorkerSinkTask rebalance callbacks Aditya Kousik (Jira)
• PR review request: Gradle build improvements Dejan Stojadinović
• [jira] [Created] (KAFKA-21268) Server Storage module: replace temp file handler with JUnit 5 Temporary Directory Support Khyati V (Jira)
• [jira] [Resolved] (KAFKA-21019) Cover consumer and share group protocols in docker sanity tests Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21266) getTopicEffectiveMinIsr should take the replicas from the target partition Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21235) The docs of sleepSecsOpt should state it is in seconds Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21270) Race condition can cause a newly created connector to use initial offsets from another request Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21269) Add tests for describing broker configs with raw string values Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21265) DescribeConfigs request fails with UNKNOWN_SERVER_ERROR on internal list config Gaurav Narula (Jira)
• [jira] [Created] (KAFKA-21267) The empty removing/adding is omitted when calculating the assignment Chia-Ping Tsai (Jira)
• New contributor interested in Apache Kafka Akshay Shinde
• [jira] [Created] (KAFKA-21264) Javadoc output language depends on the build machine's system locale Ken Huang (Jira)
• [jira] [Resolved] (KAFKA-20278) Refactor and clean the code in HeadersStoreUpgradeIntegrationTest TengYao Chi (Jira)
• [Please Review/Approve] KAFKA-19657 & KAFKA-6621 Naveen
• [PR] KAFKA-9528: Improve homepage accessibility (image alt text, footer contrast) [kafka-site] via GitHub
  • Re: [PR] KAFKA-9528: Improve homepage accessibility (image alt text, footer contrast) [kafka-site] via GitHub
  • Re: [PR] KAFKA-9528: Improve homepage accessibility (image alt text, footer contrast) [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-21222) Add broker-level configs Luke Chen (Jira)
• [jira] [Created] (KAFKA-21262) Share consumer benchmark system tests are flaky Eric Chang (Jira)
• [VOTE] 4.3.2 RC3 黃竣陽
  • Re: [VOTE] 4.3.2 RC3 Chia-Ping Tsai
  • Re: [VOTE] 4.3.2 RC3 Jakub Scholz
  • Re: [VOTE] 4.3.2 RC3 Mickael Maison
  • Re: [VOTE] 4.3.2 RC3 Bill Bejeck
• [jira] [Created] (KAFKA-21261) Base image for system test dependencies Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21260) Drop the Vagrant Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21259) Document the case of OffsetOutOfRangeException for Admin#deleteRecords Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-14333) Kafka Admin delete records java doc is missing information about supported cleanup.policy Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21258) Move the Docker image usage guide from docker/examples/README.md to the website docs Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21143) Server-only OAUTHBEARER listener with private JWKS CA triggers token login and fails broker startup Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21257) Document tokenless OAUTHBEARER login for validate-only brokers Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21110) Document that min.insync.replicas is bounded by the replica count Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21256) Assignment callback failure can stall reconciliation in the Streams protocol client sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21255) Streams heartbeat retry responses can omit assignments after response loss sanghyeok An (Jira)
• [jira] [Resolved] (KAFKA-21158) Document/warn about future timestamps allowed by message.timestamp.after.max.ms Muralidhar Basani (Jira)
• [jira] [Resolved] (KAFKA-19382) Upgrade junit from 5.10 to 5.13 Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-19347) AclControlManager unsafe state update Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-15976) KIP-995: Allow users to specify initial offsets while creating connectors Mickael Maison (Jira)
• [jira] [Created] (KAFKA-21254) Rework regex subscription ACLS Dongnuo Lyu (Jira)
• [jira] [Created] (KAFKA-21253) Failed transaction abort in RecordCollectorImpl.closeDirty() skips clearing changelog offsets, so a revived task can checkpoint a stale offset Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-21249) Pre-rebalance auto-commit retries may commit offsets beyond unprocessed records sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21252) Document the behavior of NewPartitions#increaseTo when the replicas is not consistent Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21251) kafka-streams-groups.sh --describe --topology: global store sub-topology label can collide with a real subtopology id Alieh Saeedi (Jira)
• [jira] [Resolved] (KAFKA-21119) Generator, Tools, test-common module: replace temp file handler with JUnit 5 Temporary Directory Support Mickael Maison (Jira)
• [jira] [Created] (KAFKA-21250) KRaft Controller Election Preference Mechanism Luke Chen (Jira)
• [jira] [Created] (KAFKA-21248) AsyncKafkaConsumer may auto-commit offsets for records not yet returned to the application sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21247) Refactor ClientOAuthIntegrationTest to use Keycloak in eligible test cases Jira
• [jira] [Created] (KAFKA-21246) Investigrate compression approaches for scatter-gather Nikita Shupletsov (Jira)
• [jira] [Created] (KAFKA-21245) Support hex-encoded key/value in console consumer and producer Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20632) Additional tests Nikita Shupletsov (Jira)
• [jira] [Created] (KAFKA-21243) Producer: concurrent first sends can wait an extra retry.backoff.ms for a redundant metadata refresh Viktor Klimin (Jira)
• [jira] [Created] (KAFKA-21244) Server-side consumer regex subscriptions do not honor `exclude.internal.topics` sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21242) Migrate Scala LogManager#apply to Java LogManger#create Chia-Ping Tsai (Jira)
• [VOTE] 4.3.2 RC1 黃竣陽
  • Re: [VOTE] 4.3.2 RC1 Chia-Ping Tsai
  • Re: [VOTE] 4.3.2 RC1 Bill Bejeck
  • Re: [VOTE] 4.3.2 RC1 Eric Chang
  • Re: [VOTE] 4.3.2 RC1 黃竣陽
• [jira] [Resolved] (KAFKA-21118) Connect module: replace temp file handler with JUnit 5 Temporary Directory Support Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-21242) Migrate Scala LogManager#apply to Java LogManger#create Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21038) Move LogManagerBuilder to jmh module Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21241) Increase the number of consumers in the share consumer group Prakhar Kulshrestha (Jira)
• [jira] [Resolved] (KAFKA-18477) remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21240) KRaftMetadataCache should cache metadata request information per image Kevin Wu (Jira)
• [jira] [Created] (KAFKA-21237) Remove accidental JUnit 4 usage Jira
• [jira] [Resolved] (KAFKA-21120) Clients Connect module: replace temp file handler with JUnit 5 Temporary Directory Support Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-21234) MetadataLoader can receive uncommitted data when log reads exceed MAX_BATCH_SIZE_BYTES Kevin Wu (Jira)
• [jira] [Created] (KAFKA-21238) Mutating nested sets in consumer assignor input can corrupt coordinator target assignment state sanghyeok An (Jira)
• Please approve workflow runs for two PR's (add "ci-approved" label) Dejan Stojadinović
• [VOTE] 4.4.0 RC4 Omnia Ibrahim
  • Re: [VOTE] 4.4.0 RC4 o . g . h . ibrahim
  • Re: [VOTE] 4.4.0 RC4 David Jacot
  • Re: [VOTE] 4.4.0 RC4 Chia-Ping Tsai
  • Re: [VOTE] 4.4.0 RC4 Luke Chen
  • Re: [VOTE] 4.4.0 RC4 o . g . h . ibrahim
  • Re: [VOTE] 4.4.0 RC4 Chia-Ping Tsai
  • Re: [VOTE] 4.4.0 RC4 Mickael Maison
  • Re: [VOTE] 4.4.0 RC4 o . g . h . ibrahim
  • Re: [VOTE] 4.4.0 RC4 Muralidhar Basani via dev
  • Re: [VOTE] 4.4.0 RC4 Mickael Maison
  • Re: [VOTE] 4.4.0 RC4 Maroš Orsák
• [jira] [Created] (KAFKA-21239) [CVE-2026-68497] [jackson-databind] Krishna Chidrawar (Jira)
• [jira] [Resolved] (KAFKA-21088) Client telemetry stops permanently if push payload construction fails Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-21152) LogCompactionTester should read until the end offsets instead of stopping at an empty poll Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21236) DefaultMessageFormatter should not pass the null literal to deserializers for null key/value Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21235) The docs of sleepSecsOpt should state it is in seconds Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21234) MetadataLoader can receive uncommitted data when log reads exceed MAX_BATCH_SIZE_BYTES Kevin Wu (Jira)
• [jira] [Created] (KAFKA-21233) Add DynamicClusterMirrorConfig.reconfigure logic Federico Valeri (Jira)
• [jira] [Created] (KAFKA-21232) Version ugrade: Apache ldap api and directory server dependencies Jira
• [jira] [Created] (KAFKA-21231) Convert defineInternal to define Federico Valeri (Jira)
• [jira] [Created] (KAFKA-21230) Long rebalances can cause OOM errors with transactional state stores enabled Nicholas Telford (Jira)
• [DISCUSS] KIP-1376: Support setting TLS named groups Mickael Maison
  • Re: [DISCUSS] KIP-1376: Support setting TLS named groups Paolo Patierno
  • Re: [DISCUSS] KIP-1376: Support setting TLS named groups Mickael Maison
  • Re: [DISCUSS] KIP-1376: Support setting TLS named groups Arnab nandy via dev
  • Re: [DISCUSS] KIP-1376: Support setting TLS named groups Mickael Maison
  • Re: [DISCUSS] KIP-1376: Support setting TLS named groups Arnab nandy via dev
  • Re: [DISCUSS] KIP-1376: Support setting TLS named groups Arnab Nandy via dev
  • Re: [DISCUSS] KIP-1376: Support setting TLS named groups Arnab Nandy
• [jira] [Created] (KAFKA-21229) AsyncKafkaConsumer passes null offsets to OffsetCommitCallback when an asynchronous commit fails sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21224) Add ClusterMirrorConfig Federico Valeri (Jira)
• [jira] [Created] (KAFKA-21228) The cold snapshot timer should check pending updates instead of snapshot timestamps Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21227) Speed up ColdStartStickinessIntegrationTest Jira
• [jira] [Created] (KAFKA-21223) Add TopicConfigs Federico Valeri (Jira)
• [jira] [Created] (KAFKA-21226) Add Admin client types Federico Valeri (Jira)
• [jira] [Created] (KAFKA-21225) Add Exceptions Federico Valeri (Jira)
• [jira] [Created] (KAFKA-21222) Add BrokerConfigs Federico Valeri (Jira)
• KAFKA-20684/KIP-1306 PR Review Request Aditya Kousik via dev
  • Re: KAFKA-20684/KIP-1306 PR Review Request Andrew Schofield
  • Re: KAFKA-20684/KIP-1306 PR Review Request Aditya Kousik via dev
• [jira] [Created] (KAFKA-21221) Add tokenless OAuth login class Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20687) Consider improving unused chunks reuse Lianet Magrans (Jira)
• [DISCUSS] KIP-1165: Object Consolidation for Diskless Viktor Somogyi-Vass via dev
  • Re: [DISCUSS] KIP-1165: Object Consolidation for Diskless Viktor Somogyi-Vass via dev
• [jira] [Created] (KAFKA-21220) Consumer group dynamic member close can stall with REMAIN_IN_GROUP after poll timeout sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21219) Streams group dynamic member close can stall with REMAIN\_IN\_GROUP after poll timeout sanghyeok An (Jira)
• Mirror Maker 2 Feature Requests Jeremy Bohrer
• [jira] [Created] (KAFKA-21218) TopicCommandTest should leverage topicService.createTopic Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21217) Ignored client-side rack assignment tags can prevent Streams protocol clients from starting sanghyeok An (Jira)
• Pending Jira account request [ykisana] Yahya Kisana via dev
• Cruise Control for Apache Kafka moves to the Linux Foundation Viktor Somogyi-Vass
• [jira] [Created] (KAFKA-21214) Spread every topic over its subscribers, without rack awareness David Jacot (Jira)
• [jira] [Created] (KAFKA-21216) Replace the uniform assignor with uniform assignor v2 David Jacot (Jira)
• [jira] [Created] (KAFKA-21215) Align partitions with the racks of their consumers David Jacot (Jira)
• [jira] [Created] (KAFKA-21213) Reject leading and trailing whitespace in Streams custom assignor names sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21212) Removed `client.rack` configuration is not reflected when a Streams static member rejoins sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21211) Server-side Streams rack-aware assignment configuration can accept tag keys longer than 20 characters, while the Kafka Streams client rejects such keys during `StreamsConfig` construction. sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21210) Complete the test coverage of ConsumerRebalanceListener Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21209) Improve client telemetry integration testing Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-21183) Remove MD5 and SHA-1 checksum files from our release process Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21065) Streamline `BytesApiMessageSerde` and `RemoteLogMetadataSerde` Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21208) Auto-check the signing key and verify the asc files before publishing Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21207) ReplaceField reads excluded or missing rename sources in schemaful records Abdgali Yerkingaliyev (Jira)
• Committers: please approve workflow runs for PR (add "ci-approved" label) Dejan Stojadinović
• [jira] [Resolved] (KAFKA-19277) Introduce `ConsumerGroupMessageFormatter` for the console-consumer Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21206) Enhance the docs of --formatter to showcase the available formatters Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21205) PR linter corrupts Markdown lists and fenced code blocks when rewriting descriptions Denis Coric (Jira)
• [jira] [Created] (KAFKA-21204) ListOffset may return -1 when offset is available Jun Rao (Jira)
• [jira] [Created] (KAFKA-21203) recovery could fail when a preallocated segment hits offset overflow Jun Rao (Jira)
• [jira] [Resolved] (KAFKA-21134) Fix all hardcoded version links Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21202) listTransactionStates doesn't need to hold the lock so long Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21201) Store less classic member metadata in ConsumerGroupMemberMetadataValue Dongnuo Lyu (Jira)
• [jira] [Resolved] (KAFKA-21196) Release memory held by CoordinatorExecutorImpl tasks when cancelled David Jacot (Jira)
• [jira] [Resolved] (KAFKA-21199) The ProducerFailureHandlingTest#testCannotSendToInternalTopic test case is flaky Maros Orsak (Jira)
• [DISCUSS] KIP-1379: Make server-side rack-aware assignment opt-in David Jacot
  • Re: [DISCUSS] KIP-1379: Make server-side rack-aware assignment opt-in Lucas Brutschy via dev
• [jira] [Created] (KAFKA-21200) Make server-side rack-aware assignment opt-in (KIP-1379) David Jacot (Jira)
• [jira] [Created] (KAFKA-21199) The ProducerFailureHandlingTest#testCannotSendToInternalTopic test case is flaky Maros Orsak (Jira)
• [jira] [Resolved] (KAFKA-18201) testGroupMetadataMessageFormatter fails for new consumer protocol PoAn Yang (Jira)
• Pending Jira Account Request Verification Harmit Jetani
• [PR] Add render image for render image with {version} [kafka-site] via GitHub
  • Re: [PR] KAFKA-21134 Add render image for render image with {version} [kafka-site] via GitHub
  • Re: [PR] KAFKA-21134 Add render image for render image with {version} [kafka-site] via GitHub
• [jira] [Created] (KAFKA-21198) Consider improving client-side visibility/logging for rejected Oauth token Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-21195) Use RE2/J in ClientMetricsConfigs Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-20998) Add HA task assignor Gavin Wang (Jira)
• [jira] [Created] (KAFKA-21197) Preserve original record headers if record copy enabled. Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-21196) Release memory held by CoordinatorExecutorImpl tasks when cancelled Sean Quah (Jira)
• [jira] [Created] (KAFKA-21195) Use RE2/J in ClientMetricsConfigs Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21194) Speed up the balanced task assignor and register it as a built-in assignor Gavin Wang (Jira)
• [jira] [Created] (KAFKA-21193) Speed up SuppressionIntegrationTest Jira
• [PR] MINOR: Add smjn as committer. [kafka-site] via GitHub
  • Re: [PR] MINOR: Add smjn as committer. [kafka-site] via GitHub
  • Re: [PR] MINOR: Add smjn as committer. [kafka-site] via GitHub
• [jira] [Created] (KAFKA-21192) Skip deleting remote segments when the leader epoch cache does not cover the remote log range Doyeon Kim (Jira)
• [jira] [Created] (KAFKA-21191) Rebuild the remote log aux state when a follower's leader epoch cache does not cover the remote log range Doyeon Kim (Jira)
• [jira] [Resolved] (KAFKA-21041) ClientMetricsConfigs rejects match patterns whose regex contains an equals sign Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-21188) Merging topics with different partition counts leaves some records unprocessed under the Streams Rebalance Protocol sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21190) Empty follower fails to start when the KIP-1023 fetch start offset equals the leader's log start offset Jax (Jira)
• [jira] [Resolved] (KAFKA-21149) Speed up JoinGracePeriodDurabilityIntegrationTest Ken Huang (Jira)
• [VOTE] 4.4.0 RC3 Omnia Ibrahim
  • Re: [VOTE] 4.4.0 RC3 o . g . h . ibrahim
  • Re: [VOTE] 4.4.0 RC3 Bill Bejeck
  • Re: [VOTE] 4.4.0 RC3 Bill Bejeck via dev
  • Re: [VOTE] 4.4.0 RC3 Chia-Ping Tsai
  • Re: [VOTE] 4.4.0 RC3 David Jacot
  • Re: [VOTE] 4.4.0 RC3 Omnia Ibrahim
• [jira] [Resolved] (KAFKA-21161) Source-topic changelog store gets the task's last produced offset instead of its last consumed offset when the task writes to its own source topic Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-21189) Classic members in a consumer group are loaded with the group level session timeout Dongnuo Lyu (Jira)
• [jira] [Created] (KAFKA-21187) OffsetCommit returns UNKNOWN_MEMBER_ID instead of FENCED_INSTANCE_ID for replaced classic static members in a ConsumerGroup sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21186) Add test utilities for Streams custom assignors sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21185) Update lz4 to 1.12.0 Jira
• [jira] [Created] (KAFKA-21184) Fix the race condition in share session Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21183) Remove MD5 and SHA-1 checksum files from our release process Chia-Ping Tsai (Jira)
• Bug Report - ProducerBatch.split() Straddling Signed Int Max Chris Jakins
• [jira] [Created] (KAFKA-21182) StreamsGroupDescribe does not return tasks pending revocation sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21179) Support rack-aware task assignment in the Streams group protocol sanghyeok An (Jira)
• [PR] Change order of KRaft migration revert steps [kafka-site] via GitHub
  • Re: [PR] Change order of KRaft migration revert steps [kafka-site] via GitHub
  • Re: [PR] Change order of KRaft migration revert steps [kafka-site] via GitHub
  • Re: [PR] Change order of KRaft migration revert steps [kafka-site] via GitHub
  • Re: [PR] Change order of KRaft migration revert steps [kafka-site] via GitHub
  • Re: [PR] Change order of KRaft migration revert steps [kafka-site] via GitHub
  • Re: [PR] Change order of KRaft migration revert steps [kafka-site] via GitHub
• About snappy-java CVEs (and unmaintained compression repos) Luke Chen
  • Re: About snappy-java CVEs (and unmaintained compression repos) Martin Andersson
• [VOTE] 4.3.2 RC0 黃竣陽
  • Re: [VOTE] 4.3.2 RC0 Bill Bejeck

• Earlier messages