jira  

Messages by Thread

• [jira] [Created] (KAFKA-20269) Refactor GroupMetadataManager assignment updates Sean Quah (Jira)
• [jira] [Created] (KAFKA-20268) Start group epochs at 2 Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-20248) Support fields that are not yet supported in StreamsGroup. Lucas Brutschy (Jira)
• [jira] [Commented] (KAFKA-20116) Support HA assignor in the streams rebalance protocol Lucas Brutschy (Jira)
• [jira] [Updated] (KAFKA-20231) KIP-1290: Rack-Aware Minimum In-Sync Replicas Lucas Brutschy (Jira)
• [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in storage and metadata [kafka] via GitHub
  • Re: [PR] MINOR: Replace Collections factory methods with Java 11+ equivalents in storage and metadata [kafka] via GitHub
• [PR] MINOR: Update testAsyncConsumerWithConsumerProtocolDisabled to use group.version [kafka] via GitHub
• [PR] KAFKA-20267 Move LogCleanerParameterizedIntegrationTest to storage module [kafka] via GitHub
  • Re: [PR] KAFKA-20267 Move LogCleanerParameterizedIntegrationTest to storage module [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20243) TCP connection count per client.id Mahesh Sambaram (Jira)
• [PR] KIP-646: Serializer API should support ByteBuffer [kafka] via GitHub
  • Re: [PR] KAFKA-5761: Serializer API should support ByteBuffer [kafka] via GitHub
• [jira] [Created] (KAFKA-20267) Move LogCleanerParameterizedIntegrationTest to storage module Maros Orsak (Jira)
• [jira] [Commented] (KAFKA-13392) Timeout Exception triggering reassign partitions with --bootstrap-server option hongten (Jira)
• [PR] MINOR: Set unequal assignment epochs fallback to default epoch for streams group [kafka] via GitHub
  • Re: [PR] MINOR: Set unequal assignment epochs fallback to default epoch for streams group [kafka] via GitHub
  • Re: [PR] MINOR: Set unequal assignment epochs fallback to default epoch for streams group [kafka] via GitHub
• Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (4/N) [kafka] via GitHub
• Re: [PR] KAFKA-20232: Fix WakeupException in awaitMetadataUpdate() [kafka] via GitHub
• Re: [PR] KAFKA-20220: Enable TimestampedKVStoreWithHeaders in DSL (5/N) [kafka] via GitHub
• [PR] KAFKA-13392 Fix incrementalAlterConfigs timeout when broker is down [kafka] via GitHub
  • Re: [PR] KAFKA-13392 Fix incrementalAlterConfigs timeout when broker is down [kafka] via GitHub
• [PR] KAFKA-19418: Fix for flaky verifiable producer system test (#20001) [kafka] via GitHub
  • Re: [PR] KAFKA-19418: Fix for flaky verifiable producer system test (#20001) [kafka] via GitHub
• [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
  • Re: [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
  • Re: [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
  • Re: [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
  • Re: [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
  • Re: [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
  • Re: [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
  • Re: [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
  • Re: [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
  • Re: [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
  • Re: [PR] KAFKA-20266: Add tracking of assignment timestamps [kafka] via GitHub
• [jira] [Created] (KAFKA-20266) Record assignment timestamps Sean Quah (Jira)
• [jira] [Updated] (KAFKA-20240) Update upgrade.md to mention new configs Sean Quah (Jira)
• [jira] [Updated] (KAFKA-20251) Add assignment batching and offload configs Sean Quah (Jira)
• [jira] [Updated] (KAFKA-20263) Change KeyValueWrapper to have versioned and headersStore Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20262) Changelog tombstone records drop custom headers when using headers-aware state stores Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20261) Upgrade path for plain window store to headers store Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20260) Upgrade path from plain KV store to headers store Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20259) Verify IQv1 and IQv2 does not break Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20257) Implement new behaviour in GlobalStateManagerImpl Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20256) DLQManager interace and default impl Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-20256) DLQManager interace and default impl Matthias J. Sax (Jira)
• [jira] [Commented] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat Matthias J. Sax (Jira)
• [jira] [Updated] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat Matthias J. Sax (Jira)
• [PR] MINOR: version updates for build and test dependencies [kafka] via GitHub
• [jira] [Resolved] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode Chia-Ping Tsai (Jira)
• [PR] KAFKA-20202: Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders [kafka] via GitHub
  • Re: [PR] KAFKA-20202: Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders [kafka] via GitHub
• [jira] [Resolved] (KAFKA-13678) 2nd punctuation using STREAM_TIME does not respect scheduled interval Matthias J. Sax (Jira)
• [PR] KAFKA-20257: Refactor GlobalStateManagerImpl [kafka] via GitHub
  • Re: [PR] KAFKA-20257: Refactor GlobalStateManagerImpl [kafka] via GitHub
• [PR] KAFKA-20035 Prevent data loss during partition expansion for dynamically added partitions [kafka] via GitHub
  • Re: [PR] KAFKA-20035 Prevent data loss during partition expansion for dynamically added partitions [kafka] via GitHub
• [PR] KAFKA-7952: Switch KTableAggregateTest from RocksDB to in-memory storage [kafka] via GitHub
  • Re: [PR] KAFKA-7952: Switch KTableAggregateTest from RocksDB to in-memory storage [kafka] via GitHub
• [PR] KAFKA-7952: Switch stream from RocksDB to in-memory [kafka] via GitHub
  • Re: [PR] KAFKA-7952: Switch stream from RocksDB to in-memory [kafka] via GitHub
  • Re: [PR] KAFKA-7952: Switch stream from RocksDB to in-memory [kafka] via GitHub
  • [PR] KAFKA-7952: Switch stream from RocksDB to in-memory [kafka] via GitHub
  • Re: [PR] KAFKA-7952: Switch stream store from RocksDB to in-memory [kafka] via GitHub
• [jira] [Commented] (KAFKA-19752) Move UnifiedLogTest to storage module Mickael Maison (Jira)
  • [jira] [Commented] (KAFKA-19752) Move UnifiedLogTest to storage module Ken Huang (Jira)
  • [jira] [Commented] (KAFKA-19752) Move UnifiedLogTest to storage module Mickael Maison (Jira)
• [PR] KAFKA-19752: Move parts of UnifiedLogTest to storage module [kafka] via GitHub
  • Re: [PR] KAFKA-19752: Move parts of UnifiedLogTest to storage module [kafka] via GitHub
  • Re: [PR] KAFKA-19752: Move parts of UnifiedLogTest to storage module [kafka] via GitHub
  • Re: [PR] KAFKA-19752: Move parts of UnifiedLogTest to storage module [kafka] via GitHub
  • Re: [PR] KAFKA-19752: Move parts of UnifiedLogTest to storage module [kafka] via GitHub
  • Re: [PR] KAFKA-19752: Move parts of UnifiedLogTest to storage module [kafka] via GitHub
  • Re: [PR] KAFKA-19752: Move parts of UnifiedLogTest to storage module [kafka] via GitHub
  • Re: [PR] KAFKA-19752: Move parts of UnifiedLogTest to storage module [kafka] via GitHub
• [PR] KAFKA-20185: Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders [kafka] via GitHub
  • Re: [PR] KAFKA-20185: Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders [kafka] via GitHub
  • Re: [PR] KAFKA-20185: Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders [kafka] via GitHub
  • Re: [PR] KAFKA-20185: Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders [kafka] via GitHub
  • Re: [PR] KAFKA-20185: Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders [kafka] via GitHub
• [jira] [Created] (KAFKA-20265) Add canonical URL tags to Kafka Javadoc pages to point search engines to suggest latest stable version Martijn Visser (Jira)
• [PR] KAFKA-20254: Add integration test for streams group migration with broker restart [kafka] via GitHub
  • Re: [PR] KAFKA-20254: Add integration test for streams group migration with broker restart [kafka] via GitHub
  • Re: [PR] KAFKA-20254: Add integration test for streams group migration with broker restart [kafka] via GitHub
  • Re: [PR] KAFKA-20254: Add integration test for streams group migration with broker restart [kafka] via GitHub
  • Re: [PR] KAFKA-20254: Add integration test for streams group migration with broker restart [kafka] via GitHub
  • Re: [PR] KAFKA-20254: Add integration test for streams group migration with broker restart [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20178) Move LogCleanerIntegrationTest to storage module Chia-Ping Tsai (Jira)
• [jira] [Updated] (KAFKA-20264) `MERGE_REPARTITION_TOPICS` optimization fails depending on which branch of a merged stream contains the key-changing operation appchemist (Jira)
  • [jira] [Updated] (KAFKA-20264) `MERGE_REPARTITION_TOPICS` optimization fails depending on which branch of a merged stream contains the key-changing operation appchemist (Jira)
  • [jira] [Updated] (KAFKA-20264) `MERGE_REPARTITION_TOPICS` optimization fails depending on which branch of a merged stream contains the key-changing operation appchemist (Jira)
• [jira] [Created] (KAFKA-20264) `MERGE_REPARTITION_TOPICS` optimization fails depending on which branch of a merged stream contains the key-changing operation appchemist (Jira)
• [jira] [Updated] (KAFKA-19752) Move UnifiedLogTest to storage module Chia-Ping Tsai (Jira)
• [PR] KAFKA-20254: Fix streams group creation failing when simple classic group exists [kafka] via GitHub
  • Re: [PR] KAFKA-20254: Fix streams group creation failing when simple classic group exists [kafka] via GitHub
  • Re: [PR] KAFKA-20254: Fix streams group creation failing when simple classic group exists [kafka] via GitHub
• [PR] KAFKA-20256: Add ShareGroupDLQ interface and some infra classes. [kafka] via GitHub
• [PR] KAFKA-20262: Changelog tombstone records drop custom headers when usi… [kafka] via GitHub
  • Re: [PR] KAFKA-20262: Changelog tombstone records drop custom headers when usi… [kafka] via GitHub
  • Re: [PR] KAFKA-20262: Changelog tombstone records drop custom headers when usi… [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20263) Change KeyValueWrapper to have versioned and headersStore Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20263) Change KeyValueWrapper to have versioned and headersStore Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20262) Changelog tombstone records drop custom headers when using headers-aware state stores TengYao Chi (Jira)
• [PR] KAFKA-20254: Add upgrade guide warning about classic to streams group migration in 4.2.0 [kafka] via GitHub
  • Re: [PR] KAFKA-20254: Add upgrade guide warning about classic to streams group migration in 4.2.0 [kafka] via GitHub
  • Re: [PR] KAFKA-20254: Add upgrade guide warning about classic to streams group migration in 4.2.0 [kafka] via GitHub
• [jira] [Created] (KAFKA-20261) Upgrade path for plain window store to headers store Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20260) Upgrade path from plain KV store to headers store Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20259) Verify IQv1 and IQv2 does not break Alieh Saeedi (Jira)
• [jira] [Closed] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat Alieh Saeedi (Jira)
• [jira] [Resolved] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20258) Refactor DSL store config and propagate dslStoreFormat Alieh Saeedi (Jira)
• [jira] [Assigned] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders Alieh Saeedi (Jira)
• [jira] [Assigned] (KAFKA-20185) Verify existing IQv2 methods for MeteredTimestampedKeyValueStoreWithHeaders Alieh Saeedi (Jira)
• [jira] [Created] (KAFKA-20257) Implement new behaviour in GlobalStateManagerImpl Nicholas Telford (Jira)
• [jira] [Updated] (KAFKA-20245) Implementation for dead-letter queues for share groups in Share Partition Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-20256) DLQManager interace and default impl Sushant Mahajan (Jira)
• [jira] [Created] (KAFKA-20255) Refactor DSL store config and propagate dslStoreFormat Alieh Saeedi (Jira)
• [jira] [Resolved] (KAFKA-20132) Implement TimestampedKeyValueStoreWithHeaders Alieh Saeedi (Jira)
• [jira] [Commented] (KAFKA-13663) IllegalMonitorStateException in ProducerMetadata.awaitUpdate Yu Xiao (Jira)
• [jira] [Assigned] (KAFKA-13183) Dropping nul key/value records upstream to repartiton topic not tracked via metrics Mahesh Sambaram (Jira)
• [PR] MINOR: Add test to enforce LATEST_STABLE_METADATA_VERSION sync with LATEST_PRODUCTION [kafka] via GitHub
  • Re: [PR] MINOR: Add test to enforce LATEST_STABLE_METADATA_VERSION sync with LATEST_PRODUCTION [kafka] via GitHub
  • Re: [PR] MINOR: Add test to enforce LATEST_STABLE_METADATA_VERSION sync with LATEST_PRODUCTION [kafka] via GitHub
  • Re: [PR] MINOR: Add test to enforce LATEST_STABLE_METADATA_VERSION sync with LATEST_PRODUCTION [kafka] via GitHub
• Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
  • Re: [PR] KAFKA-20222: Enable SessionStore with headers in DSL [kafka] via GitHub
• Re: [PR] Update EndToEndLatency.java [kafka] via GitHub
• Re: [PR] fix: replace 12 bare except clauses with except Exception [kafka] via GitHub
• [PR] MINOR: AbstractSegments should not swallow exceptions [kafka] via GitHub
  • Re: [PR] MINOR: AbstractSegments should not swallow exceptions [kafka] via GitHub
  • Re: [PR] MINOR: AbstractSegments should not swallow exceptions [kafka] via GitHub
  • Re: [PR] MINOR: AbstractSegments should not swallow exceptions [kafka] via GitHub
  • Re: [PR] MINOR: AbstractSegments should not swallow exceptions [kafka] via GitHub
  • Re: [PR] MINOR: AbstractSegments should not swallow exceptions [kafka] via GitHub
• [jira] [Updated] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone Matthias J. Sax (Jira)
  • [jira] [Updated] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-20254) Streams group replay fails after log compaction removes classic group tombstone Lucas Brutschy (Jira)
• [PR] MINOR: version updates: Gradle (9.2.1 -->> 9.4.0) and spotless plugin (8.0.0 -->> 8.3.0) [kafka] via GitHub
  • Re: [PR] MINOR: version updates: Gradle (9.2.1 -->> 9.4.0) and spotless plugin (8.0.0 -->> 8.3.0) [kafka] via GitHub
• [PR] Rlm [kafka] via GitHub
• [jira] [Updated] (KAFKA-20253) High CPU loop on consumer after failed re-authentication Jira
  • [jira] [Updated] (KAFKA-20253) High CPU loop on consumer after failed re-authentication Kirk True (Jira)
• [jira] [Created] (KAFKA-20253) High CPU loop on consumer after failed re-authentication Jira
• [PR] KAFKA-20162: Validation and enforcement of group configurations [kafka] via GitHub
  • Re: [PR] KAFKA-20162: Validation and enforcement of group configurations [kafka] via GitHub
• [jira] [Commented] (KAFKA-20131) ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls Kirk True (Jira)
• [jira] [Resolved] (KAFKA-20158) Implement SessionStoreWithHeaders Bill Bejeck (Jira)
• [PR] KAFKA-20207: handle the ClusterIdRecord as part of the metadata image [kafka] via GitHub
• [PR] MINOR: Ignore unassigned records in MockConsumer [kafka] via GitHub
  • Re: [PR] MINOR: Ignore unassigned records in MockConsumer [kafka] via GitHub
  • Re: [PR] MINOR: Ignore unassigned records in MockConsumer [kafka] via GitHub
  • Re: [PR] MINOR: Ignore unassigned records in MockConsumer [kafka] via GitHub
• [PR] MINOR: make processMessages task outputs relocatable for build cache [kafka] via GitHub
• Re: [PR] KAFKA-20131: ClassicKafkaConsumer does not clear endOffsetRequested flag on failed LIST_OFFSETS calls [kafka] via GitHub
• [jira] [Resolved] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq Mickael Maison (Jira)
• [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka] via GitHub
  • Re: [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka] via GitHub
  • Re: [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka] via GitHub
  • Re: [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka] via GitHub
  • Re: [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka] via GitHub
  • Re: [PR] MINOR: Upgrade LATEST_STABLE_METADATA_VERSION to match LATEST_PRODUCTION version [kafka] via GitHub
• [jira] [Assigned] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq Mickael Maison (Jira)
• [PR] MINOR: fix protocol link in templates.py [kafka] via GitHub
  • Re: [PR] MINOR: fix protocol link in templates.py [kafka] via GitHub
• [jira] [Updated] (KAFKA-20241) Jackson core vulnerability GHSA-72hv-8253-57qq Chia-Ping Tsai (Jira)
• [jira] [Commented] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils Kartikay Dubey (Jira)
  • [jira] [Commented] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils Maros Orsak (Jira)
• [jira] [Assigned] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils Kartikay Dubey (Jira)
• [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka] via GitHub
  • Re: [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka] via GitHub
  • Re: [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka] via GitHub
  • Re: [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka] via GitHub
  • Re: [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka] via GitHub
  • Re: [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka] via GitHub
  • Re: [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka] via GitHub
  • Re: [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka] via GitHub
  • Re: [PR] KAFKA-20251: Add configs for assignment batching and offload [kafka] via GitHub
• [jira] [Created] (KAFKA-20252) Migrate clearYammerMetrics to TestUtils Maros Orsak (Jira)
• [jira] [Created] (KAFKA-20251) Add assignment batching and offload configs Sean Quah (Jira)
• [jira] [Assigned] (KAFKA-20238) Kafka 4.0+ monitoring documentation still includes some controller metrics only supported in ZK mode Karl Sorensen (Jira)
• Re: [PR] MINOR: Upgrade dependencies versions for bouncycastle and jgit-related libraries [kafka] via GitHub
  • Re: [PR] MINOR: Upgrade dependencies versions for bouncycastle and jgit-related libraries [kafka] via GitHub
  • Re: [PR] MINOR: Upgrade dependencies versions for bouncycastle and jgit-related libraries [kafka] via GitHub
• [jira] [Commented] (KAFKA-13630) Client producer reduce RecordAccumulator locks in producer thread Nilesh Kumar (Jira)
• [jira] [Assigned] (KAFKA-13630) Client producer reduce RecordAccumulator locks in producer thread Nilesh Kumar (Jira)
• Re: [PR] KAFKA-19921 : Test-Common | Fixed order of arguments of assertEquals in unit tests [kafka] via GitHub
  • Re: [PR] KAFKA-19921 : Test-Common | Fixed order of arguments of assertEquals in unit tests [kafka] via GitHub
• Re: [PR] Update README.md [kafka] via GitHub
  • Re: [PR] Update README.md [kafka] via GitHub

• Earlier messages