dev  

Messages by Thread

• [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
  • Re: [DISCUSS] KIP-1379: Make server-side rack-aware assignment opt-in Andrew Schofield
• [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
  • Re: [PR] Change order of KRaft migration revert steps [kafka-site] via GitHub
  • Re: [PR] KAFKA-20488 Check controller epoch after deprovisioning KRaft quorum when reverting migration [kafka-site] via GitHub
  • Re: [PR] KAFKA-20488 Check controller epoch after deprovisioning KRaft quorum when reverting migration [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
  • Re: [VOTE] 4.3.2 RC0 Jakub Scholz
  • Re: [VOTE] 4.3.2 RC0 Chia-Ping Tsai
  • Re: [VOTE] 4.3.2 RC0 黃竣陽
  • Re: [VOTE] 4.3.2 RC0 黃竣陽
• [PR] MINOR: Add 4.2.2 docs [kafka-site] via GitHub
  • Re: [PR] MINOR: Add 4.2.2 docs [kafka-site] via GitHub
• [jira] [Created] (KAFKA-21178) Allow kafka admin to disable some compression methods Luke Chen (Jira)
• [jira] [Created] (KAFKA-21181) Transaction coordinator could return INVALID_TXN_STATE from stale cache after losing __transaction_state leadership Ritika Reddy (Jira)
• [ANNOUNCE] Apache Kafka 4.2.2 Apoorv Mittal
• [jira] [Created] (KAFKA-21180) Support user-defined processing weights for Kafka Streams task assignment sanghyeok An (Jira)
• [PR] MINOR: Fix broken 4.2.2 blog link date in downloads.md [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix broken 4.2.2 blog link date in downloads.md [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix broken 4.2.2 blog link date in downloads.md [kafka-site] via GitHub
  • Re: [PR] MINOR: Fix broken 4.2.2 blog link date in downloads.md [kafka-site] via GitHub
• [PR] MINOR: Updating versions for 4.2.2 release [kafka-site] via GitHub
  • Re: [PR] MINOR: Updating versions for 4.2.2 release [kafka-site] via GitHub
• [PR] MINOR: Correcting and adding blogpost for 4.2.2 release [kafka-site] via GitHub
  • Re: [PR] MINOR: Correcting and adding blogpost for 4.2.2 release [kafka-site] via GitHub
• [ANNOUNCE] New committer: Sushant Mahajan Andrew Schofield
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Sanskar Jhajharia via dev
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Luke Chen
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Apoorv Mittal
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Abhinav Dixit via dev
  • Re: [ANNOUNCE] New committer: Sushant Mahajan TengYao Chi
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Shivsundar R via dev
  • Re: [ANNOUNCE] New committer: Sushant Mahajan 黃竣陽
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Lianet Magrans
  • Re: [ANNOUNCE] New committer: Sushant Mahajan PoAn Yang
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Sean Quah via dev
  • Re: [ANNOUNCE] New committer: Sushant Mahajan nileshkumar3
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Sushant Mahajan
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Bill Bejeck
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Muralidhar Basani via dev
  • Re: [ANNOUNCE] New committer: Sushant Mahajan chiamin liu
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Akhilesh Chaganti
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Mickael Maison
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Kamal Chandraprakash
  • Re: [ANNOUNCE] New committer: Sushant Mahajan Sahil Devgon
• [jira] [Resolved] (KAFKA-20947) ZkWriteSnapshotTimeMs metric reports negative values Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21175) Update jackson to 2.21.7 Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21177) Refactor to pass MemberAssignment interfaces around instead of Assignments Sean Quah (Jira)
• [jira] [Created] (KAFKA-21176) GroupMetadataManager.groupsByTopics not cleaned up on consumer group downgrade Sean Quah (Jira)
• [jira] [Created] (KAFKA-21175) Update jackson to 2.21.7 Chia-Ping Tsai (Jira)
• Please provide "ci-approved" label for two PR's Dejan Stojadinović
  • Re: Please provide "ci-approved" label for two PR's Dejan Stojadinović
• [jira] [Resolved] (KAFKA-21173) Consider adding `--no-parallel` to release.py to avoid multiple staging repositories being built Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21172) Flaky StreamsUpgradeTest.test_app_upgrade: window changelogs are deleted by retention before restore Eric Chang (Jira)
• [jira] [Created] (KAFKA-21174) Update lz4 to 1.11.4 Jira
• [jira] [Resolved] (KAFKA-20691) PersisterStateBatchCombiner.combineStateBatches() is O(n^2) worst-case; replace TreeSet-based iterative merge with single-pass sweep-line Ken Huang (Jira)
• Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect pritam kumar
• [jira] [Created] (KAFKA-21173) Consider adding `--no-parallel` to release.py to avoid multiple staging repositories being built Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21154) Worker#startTask should close the instances when encountering error Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21093) Ensure all ConfigProviders get closed before throwing exception Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21075) Utils.flushFileIfExists should skip fsync on Windows and z/OS, same as flushDir Chia-Ping Tsai (Jira)
• [PR] MINOR: Add LibreDB Studio to the Powered By page [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-21133) Speed up FineGrainedAutoResetIntegrationTest Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21171) Repeated task offset snapshot rebuilding adds overhead with the Streams rebalance protocol sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21170) Validate Streams task assignor output before accepting target assignments sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21169) Streams group coordinator may trigger unnecessary rebalances on every heartbeat when a custom assignor returns empty task sets sanghyeok An (Jira)
• Request for review for PRs in kafka-site Owen Leung
• [jira] [Resolved] (KAFKA-21138) Correct the docs of `AlterConfigPolicy#validate` Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21168) The doBuild methods in Worker do not release resources on failure Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21167) StickyTaskAssignor can overlook local state when a member reaches quota sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21166) sticky assignor maybe never converge Ziyun Fu (Jira)
• [jira] [Resolved] (KAFKA-10902) IllegalMonitorStateException in KafkaProducer.waitOnMetadata Lianet Magrans (Jira)
• [jira] [Resolved] (KAFKA-14405) Log a warning when users attempt to set a config controlled by Streams Gavin Wang (Jira)
• [jira] [Resolved] (KAFKA-20697) Add cross-version system tests Gavin Wang (Jira)
• [jira] [Resolved] (KAFKA-21060) Make StickyAssignor aware of stateless vs stateful tasks Ziyun Fu (Jira)
• [jira] [Created] (KAFKA-21165) Support a different compression type for log compaction Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21164) Consider using another anchor to replace lastModified Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21155) Document that the records map passed to ConsumerRecords must not contain empty lists Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21131) Use regex in resource-config.json to avoid hardcoding versions Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21163) Uniform v2: spread every topic over its subscribers David Jacot (Jira)
• [VOTE] KIP-1368: Client framework name and version Andrew Schofield
• [jira] [Created] (KAFKA-21162) Move StreamsGroupTopologyDescriptionManager related tests out of GroupCoordinatorService Lucy Liu (Jira)
• [jira] [Created] (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-21160) improve RequestHeader parsing on the broker Jun Rao (Jira)
• [jira] [Created] (KAFKA-21159) Clear next offsets to consume on task close to avoid stale commit after revive Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-21158) Document/warn about future timestamps allowed by message.timestamp.after.max.ms and revert lastModified retention anchor Muralidhar Basani (Jira)
• [jira] [Resolved] (KAFKA-21156) Avoid unnecessary char[] copy in ProcessorRecordContext#residentMemorySizeEstimate Chia-Ping Tsai (Jira)
• Question on KIP-1023 behavior when selected fetch offset equals log start offset Jax Hodgkinson via dev
  • Re: Question on KIP-1023 behavior when selected fetch offset equals log start offset Jax Hodgkinson via dev
• [jira] [Created] (KAFKA-21157) Bump Jackson version to 2.22.3 Jira
• Follow-up on Apache Kafka Confluence Account Request Avishek Das
  • Re: Follow-up on Apache Kafka Confluence Account Request Avishek Das
• [jira] [Resolved] (KAFKA-21116) Validate configuration value size using UTF-8 bytes Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21156) Avoid unnecessary char[] copy in ProcessorRecordContext#residentMemorySizeEstimate Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-20898) PushTelemetry sets terminating flag on validation failure, permanently locking out client instance Apoorv Mittal (Jira)
• [jira] [Created] (KAFKA-21155) Document that the records map passed to ConsumerRecords must not contain empty lists Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21128) upgrade-guide.md could use more general version in describing upgrade path Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21154) Worker#startTask should close the instances when encountering error Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21153) ClusterInstance#waitTopicDeletion should not wait the file cleanup Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21152) LogCompactionTester stops at the first empty poll and misses data after compaction Eric Chang (Jira)
• [jira] [Resolved] (KAFKA-20175) Introduce new MetadataVersion for ClusterIdRecord Kevin Wu (Jira)
• [jira] [Created] (KAFKA-21151) Extract streams group topology description orchestration into a shared runtime abstraction Lucy Liu (Jira)
• [DISCUSS] Apache Kafka 4.5.0 release Andrew Schofield
  • Re: [DISCUSS] Apache Kafka 4.5.0 release Lianet Magrans
  • Re: [DISCUSS] Apache Kafka 4.5.0 release Chia-Ping Tsai
  • Re: [DISCUSS] Apache Kafka 4.5.0 release Lucas Brutschy via dev
  • Re: [DISCUSS] Apache Kafka 4.5.0 release Andrew Schofield
• [jira] [Created] (KAFKA-21150) Refactor AbstractKafkaConfig#processRoles Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21149) Speed up JoinGracePeriodDurabilityIntegrationTest Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21148) speed up JoinStoreIntegrationTest Chia-Ping Tsai (Jira)
• Re: Is KRaft dedicated controller(static quorum) → combined mode migration supported in kafka 3.9.1 Luke Chen
• [jira] [Created] (KAFKA-21147) Expose explicit config deletions to AlterConfigPolicy Chia-Ping Tsai (Jira)
• [jira] [Reopened] (KAFKA-19028) AlterConfigPolicy with OpType.DELETE : inconsistent behavior between TOPIC and BROKER resource Chia-Ping Tsai (Jira)
  • [jira] [Reopened] (KAFKA-19028) AlterConfigPolicy with OpType.DELETE : inconsistent behavior between TOPIC and BROKER resource Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21146) Test classes leak BrokerTopicStats metrics into the shared Yammer registry Chia-Ping Tsai (Jira)

• Earlier messages
• Later messages