Messages by Thread
-
Re: [PR] [KAFKA-16768] socketServer leaks accepted socketChannel instances due to race… [kafka]
via GitHub
-
Re: [PR] KAFKA-19735: Add automatic commit offset caching in subscribe mode [kafka]
via GitHub
-
Re: [PR] KAFKA: Clarify allow.everyone.if.no.acl.found documentation [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20347) Fix metric leak and JMX tag order in ShareCoordinatorMetrics
majialong (Jira)
-
[jira] [Created] (KAFKA-20347) Fix metric leak and JMX tag order in ShareCoordinatorMetrics
Chia-Ping Tsai (Jira)
-
Re: [PR] MINOR: clean typos and grammar across quickstart, connect, streams, and MirrorMaker docs [kafka]
via GitHub
-
Re: [PR] KAFKA-19562: Replace hand-written AbortedTxn with generated protocol [kafka]
via GitHub
-
[PR] KAFKA-20173: Propagate headers into serde 7/N [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-967) Use key range in ProducerPerformance
Ken Huang (Jira)
-
[jira] [Updated] (KAFKA-967) Use key range in ProducerPerformance
Chia-Ping Tsai (Jira)
-
[jira] [Commented] (KAFKA-967) Use key range in ProducerPerformance
Chia-Ping Tsai (Jira)
-
[PR] KAFKA-20173: Propagate headers into serde 6/N [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20291) Implement assignment batching
David Jacot (Jira)
-
[PR] KAFKA-17552: Handle LIST_OFFSETS request for max_timestamp when remote storage is enabled [kafka]
via GitHub
-
Re: [PR] Address KAFKA-20252: Migrate clearYammerMetrics to TestUtils [kafka]
via GitHub
-
Re: [PR] KAFKA-17397: Ensure ClassicKafkaConsumer sends leave request on close even if interrupted [kafka]
via GitHub
-
Re: [PR] KAFKA-19752 Move parts of UnifiedLogTest to storage module [kafka]
via GitHub
-
[PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
Re: [PR] KAFKA-20341: Clarify return semantics of assignment(), subscription(), and metrics() in consumer Javadoc [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20341) Clarify that assignment() and subscription() return a snapshot, not a live view
Lan Ding (Jira)
-
Re: [PR] KAFKA-18896 add KIP-877 support for Login [kafka]
via GitHub
-
Re: [PR] KAFKA-17103: MockClient tight loops when no metadata is present in KafkaProducerTest [kafka]
via GitHub
-
Re: [PR] KAFKA-19886 : Trogdor | Fix order of arguments in assertEquals in unit tests [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-14922) kafka-streams-application-reset deletes topics not belonging to specified application-id
Preethi KCS (Jira)
-
Re: [PR] Add a SelectorProvider that reuses custom provider implementations. [kafka]
via GitHub
-
Re: [PR] KAFKA-20312: Handle null leader during OffsetFetcher regroup safely [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20199) Evaluate whether BrokerId metrics tag should be renamed to NodeId or split by role
Nilesh Kumar (Jira)
-
Re: [PR] KAFKA-14648: Do not fail clients if bootstrap servers is not immediately resolvable [kafka]
via GitHub
-
Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka]
via GitHub
-
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
-
[PR] Feat/mm2 fault tolerance [kafka]
via GitHub
-
[PR] KAFKA-20346: LogCleaner#cleaners should be thread-safe [kafka]
via GitHub
-
[PR] MINOR: Fix potential NPE [kafka]
via GitHub
-
[PR] KAFKA-20050: Add syntax highlighting for code blocks and commands [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-19811) Acked record on new topic not immediately visible to consumer
Erik van Oosten (Jira)
-
[jira] [Commented] (KAFKA-18818) Significant delay in Metadata Update After Admin Client Operations in KRaft Mode
Erik van Oosten (Jira)
-
[PR] KAFKA-19752: Move UnifiedLogTest to storage module [kafka]
via GitHub
-
Re: [PR] KAFKA-20117: Improve ClusterControlManager error message [kafka]
via GitHub
-
Re: [PR] MINOR: Enhanced exception handling for metadata acquisition [kafka]
via GitHub
-
Re: [PR] KAFKA-20253: Fix high CPU loop after failed re-authentication [kafka]
via GitHub
-
Re: [PR] KAFKA-20182 version updates: Gradle (9.2.1 -->> 9.4.1) and spotless plugin (8.0.0 -->> 8.4.0) [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20346) LogCleaner#cleaners should be thread-safe
TaiJuWu (Jira)
-
[jira] [Created] (KAFKA-20346) LogCleaner#cleaners should be thread-safe
Chia-Ping Tsai (Jira)
-
Re: [PR] KAFKA-20211, KAFKA-20345: Fix group coordinator background metrics test flake [kafka]
via GitHub
-
[jira] [Comment Edited] (KAFKA-20345) Flaky CoordinatorBackgroundThreadPoolExecutorTest testMetrics
Sean Quah (Jira)
-
[jira] [Assigned] (KAFKA-20343) Refactor makeCleaner test helper overloads in LogCleanerIntegrationTest to use the builder pattern
Nilesh Kumar (Jira)
-
[jira] [Commented] (KAFKA-20343) Refactor makeCleaner test helper overloads in LogCleanerIntegrationTest to use the builder pattern
Nilesh Kumar (Jira)
-
[PR] KAFKA-20343: Refactor LogCleanerLagIntegrationTest to use a builder for LogCleaner setup [kafka]
via GitHub
-
Re: [PR] KAFKA-20297: Cleanup `org.apache.kafka.common.utils.CollectionUtils` [kafka]
via GitHub
-
Re: [PR] KAFKA-18652: Add `num.warmup.replicas` config [kafka]
via GitHub
-
Re: [PR] KAFKA-19863: Add documentation on how to implement a custom exception(with ref to DLQ) [kafka]
via GitHub
-
Re: [PR] KAFKA-20249: Optimize raw value extraction in headers-aware deserializers [kafka]
via GitHub
-
Re: [PR] KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory [kafka]
via GitHub