jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
[PR] MINOR: Bump Jackson to 2.21.2 [kafka]
via GitHub
Re: [PR] MINOR: Bump Jackson to 2.21.2 [kafka]
via GitHub
Re: [PR] MINOR: Bump Jackson to 2.21.2 [kafka]
via GitHub
[jira] [Created] (KAFKA-20427) Controllers can't form quorum on restart when hostnames changes with dynamic quorum
Paolo Patierno (Jira)
[jira] [Assigned] (KAFKA-20337) Refactor GroupConfig to be less confusing
David Jacot (Jira)
[jira] [Resolved] (KAFKA-20089) clients - update javadocs -- while topic being created in background
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-20089) clients - update javadocs -- while topic being created in background
Chia-Ping Tsai (Jira)
[jira] [Resolved] (KAFKA-20425) Avoid triggers to purgatory when no data is available for share fetch
Apoorv Mittal (Jira)
[jira] [Comment Edited] (KAFKA-20389) ConfigKeyInfo does not include 'internal' flag.
Mickael Maison (Jira)
[jira] [Assigned] (KAFKA-20426) Using both group.id and assign() causes a busy loop in AsyncKafkaConsumer
Chia-Ping Tsai (Jira)
[PR] KAFKA-20246: Add clusterId and nodeId to ApiVersionsRequest (2/N) [kafka]
via GitHub
[PR] KAFKA-20198: Fix StickyTaskAssignor capacity calculation to use proportional instance limit [kafka]
via GitHub
Re: [PR] KAFKA-20198: Fix StickyTaskAssignor capacity calculation to use proportional instance limit [kafka]
via GitHub
Re: [PR] KAFKA-20198: Fix StickyTaskAssignor capacity calculation to use proportional instance limit [kafka]
via GitHub
Re: [PR] KAFKA-20198: Fix StickyTaskAssignor capacity calculation to use proportional instance limit [kafka]
via GitHub
Re: [PR] KAFKA-20198: Fix StickyTaskAssignor capacity calculation to use proportional instance limit [kafka]
via GitHub
[jira] [Assigned] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-20426) Using both group.id and assign() causes a busy loop in AsyncKafkaConsumer
Kuan Po Tseng (Jira)
[jira] [Commented] (KAFKA-20426) Using both group.id and assign() causes a busy loop in AsyncKafkaConsumer
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-20426) Using both group.id and assign() causes a busy loop in AsyncKafkaConsumer
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-20426) Using both group.id and assign() causes a busy loop in AsyncKafkaConsumer
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-20426) Using both group.id and assign() causes a busy loop in AsyncKafkaConsumer
Kuan Po Tseng (Jira)
[jira] [Created] (KAFKA-20426) Using both group.id and assign() causes a busy loop in AsyncKafkaConsumer
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-14249: Fix flaky TLSv1.3 idle expiry test (Tls13SelectorTest.testCloseOldestConnection) [kafka]
via GitHub
Re: [PR] KAFKA-14249: Fix flaky TLSv1.3 idle expiry test (Tls13SelectorTest.testCloseOldestConnection) [kafka]
via GitHub
Re: [PR] KAFKA-18981: Fix flaky test QuorumControllerTest.testMinIsrUpdateWithElr [kafka]
via GitHub
Re: [PR] KAFKA-18981: Fix flaky test QuorumControllerTest.testMinIsrUpdateWithElr [kafka]
via GitHub
[jira] [Updated] (KAFKA-20197) Add headers support to StreamPartitioner
Bill Bejeck (Jira)
[PR] KAFKA-20391: Improve types returned by the Connect REST API [kafka]
via GitHub
Re: [PR] KAFKA-20391: Improve types returned by the Connect REST API [kafka]
via GitHub
Re: [PR] KAFKA-20391: Improve types returned by the Connect REST API [kafka]
via GitHub
Re: [PR] KAFKA-20391: Improve types returned by the Connect REST API [kafka]
via GitHub
Re: [PR] KAFKA-20391: Improve types returned by the Connect REST API [kafka]
via GitHub
Re: [PR] KAFKA-20391: Improve types returned by the Connect REST API [kafka]
via GitHub
[jira] [Assigned] (KAFKA-19409) Upgrade RocksDB dependency from 10.1.3 to something newer
Jira
[jira] [Assigned] (KAFKA-19409) Upgrade RocksDB dependency from 10.1.3 to something newer
Jira
[jira] [Resolved] (KAFKA-20194) DSL Opt-in Support for Header-Aware State Stores
Matthias J. Sax (Jira)
[PR] KAFKA-20337: Make all GroupConfig fields Optional and clean up validation [kafka]
via GitHub
Re: [PR] KAFKA-20337: Make all GroupConfig fields Optional and clean up validation [kafka]
via GitHub
Re: [PR] KAFKA-20337: Make all GroupConfig fields Optional and clean up validation [kafka]
via GitHub
Re: [PR] KAFKA-20337: Make all GroupConfig fields Optional and clean up validation [kafka]
via GitHub
Re: [PR] KAFKA-20337: Make all GroupConfig fields Optional and clean up validation [kafka]
via GitHub
Re: [PR] KAFKA-20337: Make all GroupConfig fields Optional and clean up validation [kafka]
via GitHub
[jira] [Created] (KAFKA-20422) Add DSL integration tests for header stores with explicit suppliers
Alieh Saeedi (Jira)
[jira] [Created] (KAFKA-20424) Review KafkaConsumerTest tests running for Classic only
Lianet Magrans (Jira)
[jira] [Updated] (KAFKA-20424) Review KafkaConsumerTest tests running for Classic only
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-20389) ConfigKeyInfo does not include 'internal' flag.
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-20389) ConfigKeyInfo does not include 'internal' flag.
Nilesh Kumar (Jira)
[PR] KAFKA-20425: Avoid triggers to purgatory when no data is available for share fetch [kafka]
via GitHub
Re: [PR] KAFKA-20425: Optimize purgatory triggers when no data is available for share fetch [kafka]
via GitHub
[jira] [Created] (KAFKA-20420) DSL Opt-in Support for Header-Aware State Stores (follow ups)
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-20425) Avoid triggers to purgatory when no data is available for share fetch
Apoorv Mittal (Jira)
[jira] [Updated] (KAFKA-19086) Extending support for Microsecond and Nanosecond Precision for Kafka Connect
Pritam Kumar (Jira)
[jira] [Updated] (KAFKA-20187) AsyncKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls
Kirk True (Jira)
[jira] [Commented] (KAFKA-20423) Flaky classic consumer testWakeupWithFetchDataAvailable
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-20423) Flaky classic consumer testWakeupWithFetchDataAvailable
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-20423) Flaky classic consumer testWakeupWithFetchDataAvailable
sanghyeok An (Jira)
[jira] [Created] (KAFKA-20419) Add SASL docker compose examples for single-node and multi-node clusters
Muralidhar Basani (Jira)
[jira] [Commented] (KAFKA-18812) Improve new consumer API errors upon background thread failures
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-18812) Improve new consumer API errors upon background thread failures
Nilesh Kumar (Jira)
[jira] [Commented] (KAFKA-18812) Improve new consumer API errors upon background thread failures
Nilesh Kumar (Jira)
Re: [PR] MINOR: Rename ConfiguredTopology to TopologyValidationResult [kafka]
via GitHub
Re: [PR] MINOR: Simplify ConfiguredTopology record [kafka]
via GitHub
[jira] [Updated] (KAFKA-18812) Improve new consumer API errors upon background thread failures
Lianet Magrans (Jira)
[jira] [Updated] (KAFKA-14648) Do not fail clients if bootstrap servers is not immediately resolvable
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-20423) Flaky classic consumer testWakeupWithFetchDataAvailable
Lianet Magrans (Jira)
[jira] [Commented] (KAFKA-20282) Classic consumer log recommendation for next gen Consumer rebalance protocol
Lianet Magrans (Jira)
[jira] [Assigned] (KAFKA-18812) Improve new consumer API errors upon background thread failures
TaiJuWu (Jira)
[jira] [Assigned] (KAFKA-18812) Improve new consumer API errors upon background thread failures
Lianet Magrans (Jira)
[jira] [Assigned] (KAFKA-18812) Improve new consumer API errors upon background thread failures
Nilesh Kumar (Jira)
[jira] [Created] (KAFKA-20421) Allow to Store Record Headers in State Stores (follow ups)
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-20414) StreamsPartitioner should pass in headers
Bill Bejeck (Jira)
[PR] KAFKA-20422: Add DSL integration tests for header stores with explicit suppliers [kafka]
via GitHub
Re: [PR] KAFKA-20422: Add DSL integration tests for header stores with explicit suppliers [kafka]
via GitHub
Re: [PR] KAFKA-20422: Add DSL integration tests for header stores with explicit suppliers [kafka]
via GitHub
[jira] [Commented] (KAFKA-20424) Review KafkaConsumerTest tests running for Classic only
Muralidhar Basani (Jira)
[jira] [Assigned] (KAFKA-20424) Review KafkaConsumerTest tests running for Classic only
Muralidhar Basani (Jira)
[jira] [Resolved] (KAFKA-20056) Allow to Store Record Headers in State Stores
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-20422) Add DSL integration tests for header stores with explicit suppliers
Alieh Saeedi (Jira)
[jira] [Commented] (KAFKA-20406) Use the topic-specific compression level for compaction instead of the default level
Bill Bejeck (Jira)
[jira] [Commented] (KAFKA-20406) Use the topic-specific compression level for compaction instead of the default level
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-20406) Use the topic-specific compression level for compaction instead of the default level
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-20418) Consider adding metrics for pending transaction markers and oldest transaction age
sanghyeok An (Jira)
[jira] [Assigned] (KAFKA-19701) Mark DescribeStreamsGroupTest testDescribeStreamsGroupWithShortTimeout() as flaky
Muralidhar Basani (Jira)
[PR] Marking testDescribeStreamsGroupWithShortTimeout as flaky [kafka]
via GitHub
Re: [PR] KAFKA-19701 : Marking testDescribeStreamsGroupWithShortTimeout as flaky [kafka]
via GitHub
Re: [PR] KAFKA-19701 : Marking testDescribeStreamsGroupWithShortTimeout as flaky [kafka]
via GitHub
Re: [PR] KAFKA-19701 : Marking testDescribeStreamsGroupWithShortTimeout as flaky [kafka]
via GitHub
Re: [PR] KAFKA-19701 : Marking testDescribeStreamsGroupWithShortTimeout as flaky [kafka]
via GitHub
Re: [PR] KAFKA-19701 : Marking testDescribeStreamsGroupWithShortTimeout as flaky [kafka]
via GitHub
[PR] KAFKA-20417: Add KIP-1035 self-managed offset lifecycle integration tests [kafka]
via GitHub
Re: [PR] KAFKA-20417: Add KIP-1035 self-managed offset lifecycle integration tests [kafka]
via GitHub
Re: [PR] KAFKA-20417: Add KIP-1035 self-managed offset lifecycle integration tests [kafka]
via GitHub
Re: [PR] KAFKA-20417: Add KIP-1035 self-managed offset lifecycle integration tests [kafka]
via GitHub
[PR] KAFKA-20417: Add KIP-1035 self-managed offset recovery integration tests [kafka]
via GitHub
Re: [PR] KAFKA-20417: Add KIP-1035 self-managed offset recovery integration tests [kafka]
via GitHub
Re: [PR] KAFKA-20417: Add KIP-1035 self-managed offset recovery integration tests [kafka]
via GitHub
Re: [PR] KAFKA-20417: Add KIP-1035 self-managed offset recovery integration tests [kafka]
via GitHub
Re: [PR] KAFKA-20417: Add KIP-1035 self-managed offset recovery integration tests [kafka]
via GitHub
Re: [PR] KAFKA-20417: Add KIP-1035 self-managed offset recovery integration tests [kafka]
via GitHub
Re: [PR] KAFKA-20417: Add KIP-1035 self-managed offset recovery integration tests [kafka]
via GitHub
[jira] [Created] (KAFKA-20417) Create integration tests for KIP-1035 changes
Bill Bejeck (Jira)
[jira] [Reopened] (KAFKA-20332) Ensure app thread not collecting records for partitions being revoked
Lianet Magrans (Jira)
[PR] KAFKA-20332 [2]: Handle wakeup on poll reconciliation check [kafka]
via GitHub
Re: [PR] KAFKA-20332 [2]: Handle wakeup on poll reconciliation check [kafka]
via GitHub
[jira] [Assigned] (KAFKA-12759) Kafka consumers with static group membership won't consume from newly subscribed topics
David Jacot (Jira)
[jira] [Comment Edited] (KAFKA-20155) Implement lazy deserialization mechanism
Muralidhar Basani (Jira)
[jira] [Commented] (KAFKA-20155) Implement lazy deserialization mechanism
Muralidhar Basani (Jira)
[jira] [Commented] (KAFKA-20155) Implement lazy deserialization mechanism
Shekhar Prasad Rajak (Jira)
[jira] [Commented] (KAFKA-20416) RocksDB loses entries during broker patches.
Daeho Kwon (Jira)
[jira] [Commented] (KAFKA-20416) RocksDB loses entries during broker patches.
Fabian Bell (Jira)
[jira] [Commented] (KAFKA-20416) RocksDB loses entries during broker patches.
Bill Bejeck (Jira)
[jira] [Commented] (KAFKA-20416) RocksDB loses entries during broker patches.
Fabian Bell (Jira)
[jira] [Assigned] (KAFKA-20394) Selector Channel not syneced with client Metadata
gomudayya (Jira)
[jira] [Commented] (KAFKA-20179) Avoiding headers deserialization while changelogging
Shekhar Prasad Rajak (Jira)
[PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
Re: [PR] KAFKA-20155: Implement lazy header deserialization for state stores [kafka]
via GitHub
[PR] KAFKA-20399: Implement VersionedKeyValueStoreWithHeaders [kafka]
via GitHub
Re: [PR] KAFKA-20399: Implement VersionedKeyValueStoreWithHeaders [kafka]
via GitHub
[PR] KAFKA-20415: Add share.version=2 for gated DLQ support. [kafka]
via GitHub
Re: [PR] KAFKA-20415: Add share.version=2 for gated DLQ support. [kafka]
via GitHub
Re: [PR] KAFKA-20415: Add share.version=2 for gated DLQ support. [kafka]
via GitHub
Re: [PR] KAFKA-20415: Add share.version=2 for gated DLQ support. [kafka]
via GitHub
[jira] [Updated] (KAFKA-20416) RocksDB loses entries during broker patches.
Fabian Bell (Jira)
[jira] [Comment Edited] (KAFKA-20412) Fix prefixScan for KV-Store with headers
Uladzislau Blok (Jira)
[jira] [Created] (KAFKA-20416) RocksDB loses entries during broker patches.
Fabian Bell (Jira)
[jira] [Created] (KAFKA-20415) Dynamic config for enabling dlq
Sushant Mahajan (Jira)
[jira] [Commented] (KAFKA-20412) Fix prefixScan for KV-Store with headers
Uladzislau Blok (Jira)
[jira] [Commented] (KAFKA-20412) Fix prefixScan for KV-Store with headers
Alieh Saeedi (Jira)
[jira] [Commented] (KAFKA-20414) StreamsPartitioner should pass in headers
Siddhartha Devineni (Jira)
[jira] [Commented] (KAFKA-20414) StreamsPartitioner should pass in headers
Shekhar Prasad Rajak (Jira)
[jira] [Commented] (KAFKA-20414) StreamsPartitioner should pass in headers
Uladzislau Blok (Jira)
[jira] [Commented] (KAFKA-20414) StreamsPartitioner should pass in headers
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-20414) StreamsPartitioner should pass in headers
Bill Bejeck (Jira)
[jira] [Assigned] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders
Shekhar Prasad Rajak (Jira)
[jira] [Assigned] (KAFKA-20155) Implement lazy deserialization mechanism
Shekhar Prasad Rajak (Jira)
[jira] [Updated] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders
Matthias J. Sax (Jira)
[jira] [Resolved] (KAFKA-20173) Revisit KS serde code to check if headers are passed correctly
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-20414) StreamsPartitioner should pass in headers
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20277) Verify existing IQv2 methods for SessionStoreWithHeaders
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20220) Enable TimestampedKVStoreWithHeaders in DSL
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20221) Enable TimestampedWindowStoreWithHeaders in DSL
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20263) Change KeyValueWrapper to have versioned and headersStore
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20307) Add Interactive Queries (IQv1) support for headers-aware stores
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20304) Implement all required ReadOnly*Facade classes for headers stores
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20303) Optimize deserializers and HeadersBytesStore
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20327) Add SessionStore overrides to Abstract decorators
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20219) Override `getPosition` correctly for TimestampedKeyValueStoreWithHeaders
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20260) Upgrade path from plain KV store to headers store
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-20182) Upgrade gradle to 9.3.x
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-20182) Upgrade gradle to 9.3.x
Chia-Ping Tsai (Jira)
[jira] [Updated] (KAFKA-20182) Upgrade gradle to 9.3.x
Chia-Ping Tsai (Jira)
[PR] [TEST] Test KAFKA-20362 auto fill reviewers [kafka]
via GitHub
Re: [PR] [TEST] Test KAFKA-20362 auto fill reviewers [kafka]
via GitHub
Re: [PR] [TEST] Test KAFKA-20362 auto fill reviewers [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20119) Clarify that `Consumer#unsubscribe` does not trigger auto-commit
Chia-Ping Tsai (Jira)
Re: [PR] Question: assumptions around ProduceResponse → ProducerBatch matching [kafka]
via GitHub
Re: [PR] Question: assumptions around ProduceResponse → ProducerBatch matching [kafka]
via GitHub
Re: [PR] KAFKA-16263 : Add Kafka Streams docs about available listeners/callback [kafka]
via GitHub
Re: [PR] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests [kafka]
via GitHub
Re: [PR] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests [kafka]
via GitHub
Re: [PR] KIP-891: Multiversioning in Kafka Connect - Config and Validation Tests [kafka]
via GitHub
[PR] KAFKA-20307: expose header-stores natively in IQv1 [kafka]
via GitHub
Re: [PR] KAFKA-20307: expose header-stores natively in IQv1 [kafka]
via GitHub
Re: [PR] KAFKA-20307: expose header-stores natively in IQv1 [kafka]
via GitHub
Re: [PR] KAFKA-20307: expose header-stores natively in IQv1 [kafka]
via GitHub
Re: [PR] KAFKA-20307: expose header-stores natively in IQv1 [kafka]
via GitHub
[PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka]
via GitHub
Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka]
via GitHub
Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka]
via GitHub
Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka]
via GitHub
Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka]
via GitHub
Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka]
via GitHub
Re: [PR] KAFKA-20397 Avoid blocking on fetchBuffer when metadata error is pending [kafka]
via GitHub
[jira] [Updated] (KAFKA-20413) Missing header-aware store variants for suppress() and stream-stream outer joins
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20413) Missing header-aware store variants for suppress() and stream-stream outer joins
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20413) Missing header-aware store variants for suppress() and stream-stream outer joins
Matthias J. Sax (Jira)
[PR] MINOR: Fix log statement formatting in KafkaAdminClient [kafka]
via GitHub
Re: [PR] MINOR: Fix log statement formatting in KafkaAdminClient [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20413) ListValueStore and outer join stores don't propagate headers to serdes
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20413) ListValueStore and suppress buffer stores don't propagate headers to serdes
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20413) ListValueStore and suppress buffer stores don't propagate headers to serdes
Alieh Saeedi (Jira)
[jira] [Created] (KAFKA-20413) ListValueStore and outer join stores don't propagate headers to serdes
Alieh Saeedi (Jira)
[jira] [Commented] (KAFKA-9585) Flaky Test: LagFetchIntegrationTest#shouldFetchLagsDuringRebalancingWithOptimization
Matthias J. Sax (Jira)
[PR] KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread [kafka]
via GitHub
Re: [PR] KAFKA-20398: Fix memory leak by removing StreamsThreadMetricsDelegatingReporter from metrics registry on thread [kafka]
via GitHub
[PR] MINOR: fix typo in KafkaAdminClient to align the meaning [kafka]
via GitHub
Re: [PR] MINOR: fix typo in KafkaAdminClient to align the meaning [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20412) Fix prefixScan for KV-Store with headers
Alieh Saeedi (Jira)
Earlier messages
Later messages