Messages by Thread
-
-
[jira] [Created] (KAFKA-20464) Linking stores using ConnectedStoreProvider causes corrupt topology
Stef Noten (Jira)
-
Re: [PR] KAFKA-14597: Fix record-e2e-latency to include processing delay at terminal nodes [kafka]
via GitHub
-
[jira] [Comment Edited] (KAFKA-20416) RocksDB loses entries during broker patches.
Bill Bejeck (Jira)
-
[PR] KAFKA-16937 Inline Time#waitObject to ProducerMetadata#awaitUpdate [kafka]
via GitHub
-
[PR] Add Mini HTTP Client - Kafka design patterns learning project [kafka]
via GitHub
-
[PR] KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStream into internal [kafka]
via GitHub
-
Re: [PR] KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStream into internal [kafka]
via GitHub
-
Re: [PR] KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStream into internal [kafka]
via GitHub
-
Re: [PR] KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStream into internal [kafka]
via GitHub
-
Re: [PR] KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStream into internal [kafka]
via GitHub
-
Re: [PR] KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStream into internal [kafka]
via GitHub
-
Re: [PR] KAFKA-20297 Move ByteBufferUnmapper, BufferSupplier, ChunkedBytesStream into internal [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20463) Merging a PR in kafka-site does not update the website
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-20462) ErrorHandlerContext does not provide access to original headers
Philipp Schirmer (Jira)
-
[jira] [Created] (KAFKA-20462) ErrorHandlerContext does not provide access to original headers
Philipp Schirmer (Jira)
-
[jira] [Assigned] (KAFKA-20404) Investigate/Fix bulk-excluded SpotBugs atomicity warnings
Muralidhar Basani (Jira)
-
[PR] KAFKA-20245: DLQ records exceeding max delivery count. [kafka]
via GitHub
-
[PR] KAFKA-9914: Fix replication cycle detection [kafka]
via GitHub
-
Re: [PR] Kafka changes [kafka]
via GitHub
-
Re: [PR] KAFKA-19106 : Improve SourceTask commit() hook [kafka]
via GitHub
-
Re: [PR] MINOR: Remove the flaky streams admin api test - describe streams group with short timeout [kafka]
via GitHub
-
Re: [PR] [WIP]KAFKA-19000 Flaky test report should use absolute time for links [kafka]
via GitHub
-
[PR] KAFKA-16263: Add listeners and callbacks section to Streams developer guide [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback
minjcho (Jira)
-
[jira] [Assigned] (KAFKA-16263) Add Kafka Streams docs about available listeners/callback
minjcho (Jira)
-
[jira] [Updated] (KAFKA-20365) Flaky test tests/kafkatest/tests/core/consume_bench_test.py::ConsumeBenchTest.test_consume_bench
Lianet Magrans (Jira)
-
[PR] KAFKA-20384: Add a unit test for reproducing per-record context [kafka]
via GitHub
-
[PR] KAFKA-20461: Support -1 (infinite retention) for offsets.retention.minutes [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20461) Support -1 (infinite retention) for offsets.retention.minutes
Edward (Jira)
-
[jira] [Created] (KAFKA-20461) Support -1 (infinite retention) for offsets.retention.minutes
Edward (Jira)
-
Re: [PR] [TEST] Test to see how cleanly 3.9 branch builds [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20453) Metrics of group "kafka.network.SocketServer" should have tags unique to each SocketServer
Edoardo Comar (Jira)
-
[PR] KAFKA-20443: Move RequestChannel Requests to server module [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-9368) Preserve stream-time across rebalances/restarts
Alieh Saeedi (Jira)
-
[jira] [Comment Edited] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported
Hareesh Billa (Jira)
-
[jira] [Commented] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported
Hareesh Billa (Jira)
-
[jira] [Updated] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported
Hareesh Billa (Jira)
-
[jira] [Created] (KAFKA-20460) Potential delivery slow-down for record-limit share consumers when draining record backlog
Andrew Schofield (Jira)
-
[PR] KAFKA-20453: Add nodeId and listenerType tags to SocketServer metrics [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20459) JDK 25 # UnsupportedOperationException: getSubject is not supported
Hareesh Billa (Jira)
-
[jira] [Assigned] (KAFKA-20458) AcknowledgeType.RENEW re-delivers records to application via poll() in explicit acknowledgement mode, undocumented and inconsistent with broker-side contract
Shekhar Prasad Rajak (Jira)
-
[jira] [Created] (KAFKA-20458) AcknowledgeType.RENEW re-delivers records to application via poll() in explicit acknowledgement mode, undocumented and inconsistent with broker-side contract
Shekhar Prasad Rajak (Jira)
-
[jira] [Comment Edited] (KAFKA-20148) Data Loss Risk When Disabling Remote Storage Due to Race Condition
chomingi (Jira)
-
[jira] [Commented] (KAFKA-20148) Data Loss Risk When Disabling Remote Storage Due to Race Condition
chomingi (Jira)
-
[jira] [Commented] (KAFKA-20457) Consider to exclude repartition topics from auto.offset.reset
Daeho Kwon (Jira)
-
Re: [PR] MINOR: Optimize ClientQuotasImage lookup (KAFKA-13022) [kafka]
via GitHub
-
Re: [PR] KAFKA-19971: Fix IllegalStateException from using entries after cache eviction [kafka]
via GitHub
-
Re: [PR] KAFKA-19967: Reduce GC pressure in tiered storage read path using direct memory buffers [kafka]
via GitHub
-
Re: [PR] KAFKA-19969: Add Per-Topic Observability Metrics for Remote Fetch Quota Enforcement [kafka]
via GitHub
-
Re: [PR] (WIP) KAFKA-19261 Move ConnectionQuotas to server module [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20457) Consider to exclude repartition topics from auto.offset.reset
Matthias J. Sax (Jira)
-
[jira] [Assigned] (KAFKA-20253) High CPU loop on consumer after failed re-authentication
chomingi (Jira)
-
[PR] KAFKA-20253: Trigger rejoin on heartbeat thread AuthenticationException [kafka]
via GitHub
-
[PR] MINOR: KAFKA-20297: move Crc32C Checksums and Sanitizer from utils to utils.internals [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20456) Task not found in StateUpdater throwing an exception and causing unnecessary retoration
Bill Bejeck (Jira)
-
[PR] KAFKA-20455: Wait for all producers to send startup_complete before executing system test [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20455) Wait for all producers to send startup_complete before executing system test
Kirk True (Jira)
-
[jira] [Created] (KAFKA-20455) Add timeout to verifiable_producer
Kirk True (Jira)
-
[jira] [Commented] (KAFKA-20454) Verify that `bin/kafka-consumer-groups.sh --reset-offsets` fails for "streams" group
Szabolcs Stremler (Jira)
-
[jira] [Created] (KAFKA-20454) Verify that `bin/kafka-consumer-groups.sh --reset-offsets` fails for "streams" group
Matthias J. Sax (Jira)
-
[PR] KAFKA-20441: Fix handling of cordoned log dirs [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20441) Follow ups for KIP-1066
Mickael Maison (Jira)
-
[jira] [Commented] (KAFKA-20445) Clarify that empty array implies no changes for logDirs in metadata change record
Chia-Ping Tsai (Jira)
-
[PR] MINOR: increase test visibility to public in client integration tests. [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20452) Avoid creating unnecessary empty batches in LogCleaner below the High Watermark
Kartikay Dubey (Jira)
-
[jira] [Assigned] (KAFKA-20452) Avoid creating unnecessary empty batches in LogCleaner below the High Watermark
Kartikay Dubey (Jira)
-
[jira] [Assigned] (KAFKA-20364) Remove control records reads from metadata module
Jun Cho (Jira)
-
[jira] [Assigned] (KAFKA-20429) Review async consumer single background queue design
sanghyeok An (Jira)
-
[PR] MINOR: Fix ListValueStore's restoration in headers mode [kafka]
via GitHub