dev  

Messages by Thread

• [jira] [Created] (KAFKA-21334) Test close() while async bootstrap DNS resolution is still pending TengYao Chi (Jira)
• [jira] [Created] (KAFKA-21333) Test async bootstrap DNS resolution recovering after transient failure TengYao Chi (Jira)
• [jira] [Created] (KAFKA-21332) Clarify UpdateFeatures.max_version_level deletion semantics Federico Valeri (Jira)
• [PR] MINOR: Update Kafka website to 4.4.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Update Kafka website to 4.4.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Update Kafka website to 4.4.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Update Kafka website to 4.4.0 [kafka-site] via GitHub
  • Re: [PR] MINOR: Update Kafka website to 4.4.0 [kafka-site] via GitHub
• [jira] [Created] (KAFKA-21331) doc fix about the tested OS Luke Chen (Jira)
• [jira] [Created] (KAFKA-21330) Extract the dedicated test cases for DynamicLogConfig from DynamicBrokerConfigTest Chia-Ping Tsai (Jira)
• Status of KIP-1266: Making the __remote_log_metadata Topic Compacted Avishek Das
• [jira] [Created] (KAFKA-21329) Update outdated steps in SSL docs Jira
• [jira] [Created] (KAFKA-21328) Add CI check for stale version references in docs/ Omnia Ibrahim (Jira)
• [jira] [Created] (KAFKA-21327) Replace JGit calls in build.gradle with the git CLI via providers.exec Jira
• [jira] [Created] (KAFKA-21326) Enable Gradle configuration cache Jira
• Review request for my first Apache Kafka contributions Akshatha Ramesh
• [jira] [Created] (KAFKA-21325) Enable asynchronous bootstrap DNS resolution by default TengYao Chi (Jira)
• [jira] [Created] (KAFKA-21324) rong parameter order in private ctor Michael Koepf (Jira)
• [jira] [Created] (KAFKA-21323) Remove deprecated java.util.regex fallback for client-metrics match patterns (KIP-714) Ojasva Jain (Jira)
• [jira] [Resolved] (KAFKA-21058) Remove the dead code from jsonNodeToInt and jsonNodeToLong Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-12188) SaslAuthenticatorTest: assert the specific failure reason instead of catching any AssertionFailedError Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21258) Move the Docker image usage guide from docker/examples/README.md to the website docs Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21322) LogConfig cleanup Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21321) Streams group: the assignment refiner does not see a member that joins in the same heartbeat Gavin Wang (Jira)
• Kafka 4.4.0 already on maven repo, is that okay? Erik van Oosten via dev
  • Re: Kafka 4.4.0 already on maven repo, is that okay? Chia-Ping Tsai
• [jira] [Resolved] (KAFKA-21280) SslTransportLayer.transferFrom sends stale buffer contents after a failed file read Jun Rao (Jira)
• [jira] [Resolved] (KAFKA-16304) Disk I/O error does not offline log directory while handling Fetch requests Jun Rao (Jira)
• [DISCUSS] KIP-1383: Standard record headers for content type Andrew Schofield
• [PR] MINOR: Update Kafka website to 4.3.2 [kafka-site] via GitHub
  • Re: [PR] MINOR: Update Kafka website to 4.3.2 [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-20858) Refactor SubscriptionState to give cleaner separation for share groups Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-21320) Sort copartition groups and indexes on the Streams client side sanghyeok An (Jira)
• [jira] [Resolved] (KAFKA-21307) Update ShareConsumeBenchSpec with addition params to support share group DLQ Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-21288) Add MirrorPartitionState Federico Valeri (Jira)
• [jira] [Created] (KAFKA-21319) Share partition read_committed acquire throws "Batch record not found" when the start offset is inside an aborted transaction batch Charles-Eddy (Jira)
• [jira] [Created] (KAFKA-21318) invertedTargetAssignment invalid for share groups Sean Quah (Jira)
• [jira] [Created] (KAFKA-21317) Timestamp lookup can miss valid offsets after the log start offset advances Shantanu Kawale (Jira)
• [jira] [Created] (KAFKA-21316) Removed entries in PartitionStates stay chained and slow down young GC on follower brokers ILKYUN LIM (Jira)
• [jira] [Created] (KAFKA-21315) Share partition stops delivering records after an acknowledgement is rolled back below a moved start offset Charles-Eddy (Jira)
• [jira] [Resolved] (KAFKA-15560) Upgrade argparse4j to 0.9.0 Mickael Maison (Jira)
• [jira] [Created] (KAFKA-21313) Share partition acquire fails with "Existing acquisition lock timeout exists" after a log start offset move splits a batch with a pending release Charles-Eddy (Jira)
• [jira] [Created] (KAFKA-21314) Share partition acquire throws "inconsistent range" at the in-flight limit on a compacted topic Charles-Eddy (Jira)
• [DISCUSS] KIP-1384: Base image for system test dependencies PoAn Yang
  • Re: [DISCUSS] KIP-1384: Base image for system test dependencies Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1384: Base image for system test dependencies PoAn Yang
• [jira] [Created] (KAFKA-21312) Snapshottable tasks in the coordinator runtime Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-17688) Move TransactionsTest to storage module Ken Huang (Jira)
• [jira] [Created] (KAFKA-21311) Throw when uncompressed records need more buffer space Evan Zhou (Jira)
• [jira] [Created] (KAFKA-21306) Streams group: a static member that rejoins from a new process can put a task on that process twice Gavin Wang (Jira)
• [jira] [Created] (KAFKA-21305) Bump Jackson version to 2.22.4 Jira
• [PR] Bump hugo-extended from 0.164.0 to 0.168.0 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.164.0 to 0.168.0 [kafka-site] via GitHub
• [jira] [Resolved] (KAFKA-21293) SubscriptionState#unsubscribe should not reset the rebalance listener Chia-Ping Tsai (Jira)
• [jira] [Reopened] (KAFKA-21255) Streams heartbeat retry responses can omit assignments after response loss Lucas Brutschy (Jira)
• [jira] [Resolved] (KAFKA-21255) Streams heartbeat retry responses can omit assignments after response loss Lucas Brutschy (Jira)
• [jira] [Created] (KAFKA-21310) Add sugar method "join" to KafkaFuture Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21309) Consumer using SubscriptionPattern throws IllegalStateException on Metadata response for a deleted assigned topic" James Palmer (Jira)
• [jira] [Created] (KAFKA-21308) StickyTaskAssignor: a full previous member hides other previous members that have room Ziyun Fu (Jira)
• Interest in an end-of-study internship (AI / ML / MLOps) at Kafka fattouchazer
• [jira] [Resolved] (KAFKA-20391) Improve types returned by the Connect REST API Mickael Maison (Jira)
• [jira] [Created] (KAFKA-21307) Update ShareConsumeBenchSpec with addition params to support share group DLQ Sushant Mahajan (Jira)
• [Bug report] Java consumer with SubscriptionPattern stops refreshing metadata after an assigned topic is deleted (4.1+) James Palmer via dev
  • Re: [Bug report] Java consumer with SubscriptionPattern stops refreshing metadata after an assigned topic is deleted (4.1+) David Jacot via dev
  • Re: [Bug report] Java consumer with SubscriptionPattern stops refreshing metadata after an assigned topic is deleted (4.1+) Lianet Magrans
• [jira] [Created] (KAFKA-21304) Add `mirror.state.topic.min.isr` and other related configs Luke Chen (Jira)
• [jira] [Resolved] (KAFKA-21226) Add Admin client types Federico Valeri (Jira)
• [jira] [Resolved] (KAFKA-21257) Document tokenless OAUTHBEARER login for validate-only brokers Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21303) Incorrect session timeout applied to classic members when reloading a consumer group sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21302) Streams group joins rejected due to copartition topic ordering differences sanghyeok An (Jira)
• Flaky Test Report returns Develocity API 401 but workflow succeeds chiamin liu
• [jira] [Created] (KAFKA-21301) Streams Group Assignment delays temporarily stop processing existing Streams tasks sanghyeok An (Jira)
• [jira] [Resolved] (KAFKA-20642) Support character ranges in Kafka shell globs Sean Quah (Jira)
• Security advisory: PR review request Dejan Stojadinović
• [jira] [Created] (KAFKA-21300) Streams group task ownership index is not rolled back, blocking valid task assignments sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21299) Fix wrapper jar checksum validation in Gradle 9.8.1 Jira
• [jira] [Created] (KAFKA-21298) Pending offset resets are lost during task recreation, causing missing processing results under exactly-once semantics sanghyeok An (Jira)
• [jira] [Resolved] (KAFKA-21268) Server, Shell, Storage module: replace temp file handler with JUnit 5 Temporary Directory Support Mickael Maison (Jira)
• [jira] [Created] (KAFKA-21297) Refactor the maybeUpdateLimitOffsetsForStandbyChangelogs Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21296) OAuth login calls do not apply default timeouts as defined in KIP-768 Lianet Magrans (Jira)
• [jira] [Created] (KAFKA-21295) Kafka Producer stalls when crossing seqnum 2^31 with MESSAGE_TOO_LARGE Chris (Jira)
• [jira] [Resolved] (KAFKA-14218) replace temp file handler with JUnit 5 Temporary Directory Support Mickael Maison (Jira)
• [DISCUSS] KIP-1381: Allow Brokers to Disable Compression Types for Client Writes Arnab nandy via dev
• [DISCUSS] KIP-1382: Expose Explicit Configuration Deletions to AlterConfigPolicy Arnab nandy via dev
  • Re: [DISCUSS] KIP-1382: Expose Explicit Configuration Deletions to AlterConfigPolicy Edoardo Comar
  • Re: [DISCUSS] KIP-1382: Expose Explicit Configuration Deletions to AlterConfigPolicy Arnab nandy via dev
• [jira] [Created] (KAFKA-21294) The example of "Configuring Production Kafka Brokers" does not work since the login callback is missing Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21293) SubscriptionState#unsubscribe should not reset the rebalance listener Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21292) Update docs of MockConsumer to use RebalanceListener Chia-Ping Tsai (Jira)
• Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #220 Apache Jenkins Server
• [jira] [Created] (KAFKA-21291) Cleanup AbstractConsumerTest Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-21079) KafkaStreams StateUpdater Thread Death Causes StreamThread Permanent Deadlock,as a result, KafkaStreams is always in the PENDING_SHUTDOWN state. Nikita Shupletsov (Jira)
• [jira] [Created] (KAFKA-21290) Add ASF allowlist check to CI workflows Omnia Ibrahim (Jira)
• [jira] [Created] (KAFKA-21284) Upgrade ClassGraph version from 4 to 5 Jira
• [jira] [Created] (KAFKA-21289) elease.py stage-docs writes documentation to the pre-Hugo flat layout instead of the KIP-1133 Hugo layout Omnia Ibrahim (Jira)
• [jira] [Created] (KAFKA-21288) Add MirrorPartitionState Federico Valeri (Jira)
• [jira] [Created] (KAFKA-21287) Fix 'licenses' folder contents and 'LICENSE-binary' file references Jira
• [jira] [Created] (KAFKA-21286) Share consumer may delay fatal startup errors while waiting for the first heartbeat Kuan Po Tseng (Jira)
• [jira] [Resolved] (KAFKA-21153) ClusterInstance#waitTopicDeletion should not wait the file cleanup Ken Huang (Jira)
• [jira] [Resolved] (KAFKA-21080) KafkaStreams pendingTasksToInit Task Handle Leak on Unclean Shutdown Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-21285) Dynamic configs less than half the value in server.properties will not take effect after restart in kraft mode yuzhou (Jira)
• [jira] [Resolved] (KAFKA-20924) Introduce request header version 3 in GetTelemetrySubscriptions and PushTelemetry RPCs Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-21283) Fix StreamThreadTest teardown race causing thread leaks and cascading test failures Ken Huang (Jira)
• [jira] [Resolved] (KAFKA-21223) Add topic-level configs Luke Chen (Jira)
• [jira] [Created] (KAFKA-21282) ThreadMetadata.restoreConsumerClientId() returns the wrong client id for the restore consumer Bill Bejeck (Jira)
• [jira] [Created] (KAFKA-21281) MM2 sync can fail due to controller record limit being hit Gaurav Narula (Jira)
• [jira] [Created] (KAFKA-21280) SslTransportLayer.transferFrom sends stale buffer contents after a failed file read Mykyta Bozhenko (Jira)
• [jira] [Created] (KAFKA-21276) Standby tasks with a source-topic changelog buffer restore records without limit Eric Chang (Jira)
• [jira] [Created] (KAFKA-21278) interactive-queries.md still states the removed methods Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-21279) Consumer and Streams group leave append failures can lose session timers and stall reassignment sanghyeok An (Jira)
• [jira] [Created] (KAFKA-21277) Docker image: support KRaft dynamic quorum (KIP-853) controllers Maros Orsak (Jira)
• [jira] [Created] (KAFKA-21275) Migrate AuthorizerIntegrationTest to Java and separate protocol-level and client API tests Ken Huang (Jira)
• [PR] Bump hugo-extended from 0.164.0 to 0.167.0 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.164.0 to 0.167.0 [kafka-site] via GitHub
  • Re: [PR] Bump hugo-extended from 0.164.0 to 0.167.0 [kafka-site] via GitHub
• [VOTE] KIP-1322: Add metrics to Kraft that measure the number of fetch timeouts and election timeouts Tony Tang via dev
  • Re: [VOTE] KIP-1322: Add metrics to Kraft that measure the number of fetch timeouts and election timeouts Kevin Wu
• [jira] [Resolved] (KAFKA-19804) Improve heartbeat request manager initial HB interval TengYao Chi (Jira)
• [jira] [Resolved] (KAFKA-21151) Extract streams group topology description orchestration into a shared runtime abstraction Lucy Liu (Jira)
• [jira] [Created] (KAFKA-21274) Remove unused javax jaxb-api and activation dependencies Jira
• [jira] [Created] (KAFKA-21273) Improve refiner performance Gavin Wang (Jira)
• [jira] [Created] (KAFKA-21272) localLogStartOffset is not advanced when remote storage is enabled on an existing topic Doyeon Kim (Jira)
• Qestions for migrating KRaft kafka dedicated controllers to combined broker/controller role nodes Xiong, Benson via dev
• [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
  • Re: [VOTE] 4.3.2 RC3 David Jacot
  • Re: [VOTE] 4.3.2 RC3 Eric Chang
  • Re: [VOTE] 4.3.2 RC3 黃竣陽
• [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

• Earlier messages