Messages by Thread
-
-
[jira] [Updated] (KAFKA-20569) Doc doesn't have upgrading steps
Christo Lolov (Jira)
-
[jira] [Updated] (KAFKA-20336) Update docs
Christo Lolov (Jira)
-
[jira] [Updated] (KAFKA-20335) Update docs
Christo Lolov (Jira)
-
[jira] [Updated] (KAFKA-20629) Add ducktape system tests for topology description plugin
Lucas Brutschy (Jira)
-
[jira] [Updated] (KAFKA-20627) Add broker integration tests for topology description plugin
Lucas Brutschy (Jira)
-
[PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
Re: [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
Re: [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
Re: [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
Re: [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
Re: [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
Re: [PR] KAFKA-20626: Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20725) Provide in-rack traffic observability for clients and brokers
Ivan Yurchenko (Jira)
-
[jira] [Updated] (KAFKA-20725) Provide in-rack traffic observability for clients and brokers
Ivan Yurchenko (Jira)
-
[jira] [Updated] (KAFKA-20724) Topology pausing may have race condition
Lucas Brutschy (Jira)
-
[jira] [Created] (KAFKA-20724) Topology pausing may have race condition
Lucas Brutschy (Jira)
-
[jira] [Comment Edited] (KAFKA-20721) Streams state updater: remove() during rebalance revocation can complete with null and throw a fatal "Task was not found in the state updater. This indicates a bug."
Lucas Brutschy (Jira)
-
[PR] KAFKA-20723: Add fail fast check for share group dlq(...). [1/N] [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20626) Add topology description to Admin client, DescribeStreamsGroups handler, and CLI tools
Lucas Brutschy (Jira)
-
[jira] [Assigned] (KAFKA-20625) Add StreamsGroupTopologyDescriptionRequestManager and Streams client topology push
Lucas Brutschy (Jira)
-
[jira] [Commented] (KAFKA-20723) Harden ShareGroupDLQStateManager
Sushant Mahajan (Jira)
-
[jira] [Created] (KAFKA-20723) Harden ShareGroupDLQStateManager
Sushant Mahajan (Jira)
-
[jira] [Commented] (KAFKA-20721) Streams state updater: remove() during rebalance revocation can complete with null and throw a fatal "Task was not found in the state updater. This indicates a bug."
Lucas Brutschy (Jira)
-
Re: [PR] (WIP-PoC) KIP-1356: IQv2 TimestampedKeyWithHeadersQuery for headers-aware state stores [kafka]
via GitHub
-
Re: [PR] KAFKA-19919: Avoid reverse DNS for built-in SASL servers [kafka]
via GitHub
-
Re: [PR] KAFKA-8035: Add lambda and anonymous class tests for KStream API generics [kafka]
via GitHub
-
Re: [PR] KAFKA-20692: Add unit tests for ToolsUtils [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20722) fix GHSA-47qp-hqvx-6r3f and GHSA-2r2c-cx56-8933
Aleksei Veremeev (Jira)
-
[jira] [Created] (KAFKA-20722) fix GHSA-47qp-hqvx-6r3f and GHSA-2r2c-cx56-8933
Aleksei Veremeev (Jira)
-
[PR] KAFKA-20695: Extend "describe group" to return "task offset" metadata [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20721) Streams state updater: remove() during rebalance revocation can complete with null and throw a fatal "Task was not found in the state updater. This indicates a bug."
Eswarar Siva (Jira)
-
Re: [PR] MINOR: Fix missing parenthesis in under-min-ISR trace log [kafka]
via GitHub
-
[PR] MINOR: optimize cooperative assignment validation [kafka]
via GitHub
-
Re: [PR] KAFKA-17871: avoid blocking the herder thread when producer flushing hangs [kafka]
via GitHub
-
[PR] KAFKA-20718: Fix flaky test OffsetStorageReaderTest.testClosingOffsetReaderWhenOffsetStoreHangsAndHasIncompleteFutures [kafka]
via GitHub
-
Re: [PR] KAFKA-20553: Eliminate the dependencies on sourceSets.test.output for streams [kafka]
via GitHub
-
Re: [PR] KAFKA: Clarify allow.everyone.if.no.acl.found documentation [kafka]
via GitHub
-
Re: [PR] updated request metrics documentation to apply for all APIs [kafka]
via GitHub
-
[jira] [Commented] (KAFKA-20720) Review level for client-side log on share session errors
Nilesh Kumar (Jira)
-
[jira] [Created] (KAFKA-20720) Review level for client-side log on share session errors
Nilesh Kumar (Jira)
-
[jira] [Assigned] (KAFKA-20720) Review level for client-side log on share session errors
Nilesh Kumar (Jira)
-
[PR] KAFKA-20700: Resolve symlinks in AllowedPaths before validation [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20719) "Streams" group sticky assignor not sticky at startup
Matthias J. Sax (Jira)
-
[jira] [Commented] (KAFKA-20719) "Streams" group sticky assignor not sticky at startup
Matthias J. Sax (Jira)
-
[PR] KAFKA-20719: Add integration test for sticky task assignment on startup [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20719) "Streams" group sticky assignor not sticky at startup
Matthias J. Sax (Jira)
-
[jira] (KAFKA-7371) Finally deprecate org.apache.kafka.common.serialization.ExtendedSerializer
Deepa Maria Polson (Jira)
-
[jira] [Updated] (KAFKA-20718) Flaky: OffsetStorageReaderTest -> testClosingOffsetReaderWhenOffsetStoreHangsAndHasIncompleteFutures
majialong (Jira)
-
[jira] [Created] (KAFKA-20718) Flaky: OffsetStorageReaderTest -> testClosingOffsetReaderWhenOffsetStoreHangsAndHasIncompleteFutures
majialong (Jira)
-
Re: [PR] KAFKA-20642: Support character ranges in Kafka shell globs [kafka]
via GitHub
-
Re: [PR] KAFKA-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy (1/N) [kafka]
via GitHub
-
Re: [PR] KAFKA-19753: Fix duplicated topic metrics in FetchMetricsManager for topic names containing dots [kafka]
via GitHub
-
Re: [PR] KAFKA-19902: fix(consumer): use latest leader epoch when committing offsets [kafka]
via GitHub
-
Re: [PR] MINOR: Followup Add KIP-1284 into streams upgrade document [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-17251) KafkaStreams.cleanup() semantics unclear
Matthias J. Sax (Jira)
-
[jira] [Resolved] (KAFKA-17251) KafkaStreams.cleanup() semantics unclear
Matthias J. Sax (Jira)
-
Re: [PR] KAFKA-17251: Avoid WARN on cleanup when state directory only contains process metadata. [kafka]
via GitHub
-
Re: [PR] KAFKA-20664: Clarify docs on max compaction lag, segment.ms, and segment.bytes for active segment rolling [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20664) Improve docs about "max compaction lag", "segment.ms" and "segment.size" with regard to active segment rolling
Matthias J. Sax (Jira)
-
[PR] MINOR: add missing log enabled check [kafka]
via GitHub
-
[PR] MINOR: Test Producer's and Accumulator's Behavior When Batch Size is Zero [kafka]
via GitHub
-
[PR] KAFKA-20624: Wire topology description plugin into GroupCoordinatorService — read path (describe) and broker wiring [kafka]
via GitHub
-
[PR] KAFKA-20494: Transactional InMemoryKeyValueStore [kafka]
via GitHub
-
[PR] KAFKA-20493: Transactional RocksDBStore [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20491) Enforce transaction buffer memory limitstatestore.uncommitted.max.bytes
Bill Bejeck (Jira)
-
[jira] [Commented] (KAFKA-20694) Fix share coordinator readState leaderEpoch -1 sentinel fencing
Lianet Magrans (Jira)
-
[PR] MINOR: Bump Setup Gradle to 6.2.0 [kafka]
via GitHub
-
[PR] MINOR: Improve handling adding metadata versions [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20717) Add KIP-1331 broker-side observability sensors (plugin.setTopology / plugin.getTopology)
TengYao Chi (Jira)
-
Re: [PR] MINOR: avoid redundant HashMap lookups and simplify Uuid conversions [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20716) LSO stuck after unclean leader election
Luke Chen (Jira)
-
[jira] [Commented] (KAFKA-20716) LSO stuck after unclean leader election
Luke Chen (Jira)
-
[jira] [Created] (KAFKA-20716) LSO stuck after unclean leader election
Luke Chen (Jira)
-
[jira] [Created] (KAFKA-20715) Cluster Mirroring - Synchronous mode
Omnia Ibrahim (Jira)