jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] KAFKA-19919: Avoid reverse DNS for built-in SASL servers [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-19919) Network Threads Blocked by Synchronous Reverse DNS Lookups During Connection Establishment
Shlomit (Jira)
[jira] [Comment Edited] (KAFKA-19919) Network Threads Blocked by Synchronous Reverse DNS Lookups During Connection Establishment
Yunseop Eom (Jira)
[jira] [Comment Edited] (KAFKA-19919) Network Threads Blocked by Synchronous Reverse DNS Lookups During Connection Establishment
Yunseop Eom (Jira)
[jira] [Comment Edited] (KAFKA-19919) Network Threads Blocked by Synchronous Reverse DNS Lookups During Connection Establishment
Yunseop Eom (Jira)
[jira] [Commented] (KAFKA-19919) Network Threads Blocked by Synchronous Reverse DNS Lookups During Connection Establishment
Shlomit (Jira)
[jira] [Commented] (KAFKA-19919) Network Threads Blocked by Synchronous Reverse DNS Lookups During Connection Establishment
Yunseop Eom (Jira)
Re: [PR] KAFKA-19983: Fix MockProcessorContext doesn't work with WindowStores. [kafka]
via GitHub
Re: [PR] KAFKA-19983: Fix MockProcessorContext doesn't work with WindowStores. [kafka]
via GitHub
Re: [PR] KAFKA-19983: Fix MockProcessorContext doesn't work with WindowStores. [kafka]
via GitHub
Re: [PR] KAFKA-19983: Fix MockProcessorContext doesn't work with WindowStores. [kafka]
via GitHub
Re: [PR] KAFKA-18870 Implement describeDelegationToken for controller [kafka]
via GitHub
Re: [PR] KAFKA-18870 Implement describeDelegationToken for controller [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-20539 Prevent Hot Data Loss on Partition Expansion for Latest Policy (1/N) [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-20657: Fix JsonConverter ByteBuffer BYTES serialization [kafka]
via GitHub
Re: [PR] KAFKA-20384: Add a unit test for reproducing per-record context [kafka]
via GitHub
[jira] [Resolved] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-7493: Remove obsolete controller bounce-at-start Streams test [kafka]
via GitHub
Re: [PR] KAFKA-7493: Remove obsolete controller bounce-at-start Streams test [kafka]
via GitHub
Re: [PR] MINOR: Simplify Tests Independent from Consumer in BaseProducerSendTest [kafka]
via GitHub
Re: [PR] MINOR: Simplify Tests Independent from Consumer in BaseProducerSendTest [kafka]
via GitHub
[PR] updated request metrics documentation to apply for all APIs [kafka]
via GitHub
Re: [PR] updated request metrics documentation to apply for all APIs [kafka]
via GitHub
Re: [PR] updated request metrics documentation to apply for all APIs [kafka]
via GitHub
Re: [PR] updated request metrics documentation to apply for all APIs [kafka]
via GitHub
[PR] MINOR: Fix typos in comments and exception messages [kafka]
via GitHub
Re: [PR] MINOR: Fix typos in comments and exception messages [kafka]
via GitHub
Re: [PR] MINOR: Fix typos in comments and exception messages [kafka]
via GitHub
Re: [PR] KAFKA-2341 Add standard deviation as metric [kafka]
via GitHub
[PR] KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for core module [kafka]
via GitHub
Re: [PR] KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for core module [kafka]
via GitHub
Re: [PR] KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for core module [kafka]
via GitHub
Re: [PR] KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for core module [kafka]
via GitHub
Re: [PR] KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for core module [kafka]
via GitHub
Re: [PR] KAFKA-20553 Eliminate the dependencies on sourceSets.test.output for core module [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20531) ducker-ak: Add --clean-build option to replace REBUILD env var
Maros Orsak (Jira)
[jira] [Resolved] (KAFKA-20379) ducker-ak has no option to skip the gradlew systemTestLibs build step
Maros Orsak (Jira)
[jira] [Updated] (KAFKA-20531) ducker-ak: Add --clean-build option to replace REBUILD env var
Maros Orsak (Jira)
[jira] [Updated] (KAFKA-20379) ducker-ak has no option to skip the gradlew systemTestLibs build step
Maros Orsak (Jira)
[jira] [Assigned] (KAFKA-20531) ducker-ak: Add --clean-build option to replace REBUILD env var
Maros Orsak (Jira)
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-20412: Fix prefixScan for KV-Store with headers [kafka]
via GitHub
Re: [PR] KAFKA-16768: SocketServer leaks accepted SocketChannel instances due to race condition [kafka]
via GitHub
Re: [PR] KAFKA-16768: SocketServer leaks accepted SocketChannel instances due to race condition [kafka]
via GitHub
Re: [PR] WIP: KAFKA-20292: Handle membership changes during offloaded assignments [kafka]
via GitHub
Re: [PR] KAFKA-19404: Align Connect plugin.path docs with actual behavior [kafka]
via GitHub
Re: [PR] KAFKA-19404: Align Connect plugin.path docs with actual behavior [kafka]
via GitHub
Re: [PR] KAFKA-20651: Cache parsed KafkaPrincipal in StandardAcl (#v1) [kafka]
via GitHub
Re: [PR] KAFKA-20651: Cache parsed KafkaPrincipal in StandardAcl (#v1) [kafka]
via GitHub
Re: [PR] KAFKA-20651: Cache parsed KafkaPrincipal in StandardAcl (#v1) [kafka]
via GitHub
Re: [PR] KAFKA-20292 [2/N]: Prepare to split TargetAssignmentBuilders [kafka]
via GitHub
Re: [PR] KAFKA-20292 [2/N]: Prepare to split TargetAssignmentBuilders [kafka]
via GitHub
Re: [PR] KAFKA-20292 [2/N]: Prepare to split TargetAssignmentBuilders [kafka]
via GitHub
Re: [PR] KAFKA-20292 [2/N]: Prepare to split TargetAssignmentBuilders [kafka]
via GitHub
Re: [PR] KAFKA-20644: Fail fast when admin.listeners overlaps listeners [kafka]
via GitHub
[PR] MINOR: Followup Add KIP-1284 into streams document [kafka]
via GitHub
Re: [PR] MINOR: Followup Add KIP-1284 into streams upgrade document [kafka]
via GitHub
Re: [PR] KAFKA-20379: ducker-ak has no option to skip the gradlew systemTestLibs build step [kafka]
via GitHub
[PR] KAFKA-19602: fix(streams): propagate state store names from KTable.transformValues to downstream KTable join [kafka]
via GitHub
Re: [PR] KAFKA-19602: fix(streams): propagate state store names from KTable.transformValues to downstream KTable join [kafka]
via GitHub
Re: [PR] KAFKA-19602: fix(streams): propagate state store names from KTable.transformValues to downstream KTable join [kafka]
via GitHub
Re: [PR] KAFKA-19602: fix(streams): propagate state store names from KTable.transformValues to downstream KTable join [kafka]
via GitHub
Re: [PR] KAFKA-19602: fix(streams): propagate state store names from KTable.transformValues to downstream KTable join [kafka]
via GitHub
[PR] KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for Streams Rebalance Protocol. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20169: Add ducktape test code for static membership in KIP-1071 [kafka]
via GitHub
Re: [PR] KAFKA-20362: Make reviewer-trailer auto-fill work on all contributors and comments [kafka]
via GitHub
Re: [PR] KAFKA-20362: Make reviewer-trailer auto-fill work on all contributors and comments [kafka]
via GitHub
[PR] KAFKA-19465: feat(connect): add value.type config to InsertHeader SMT [kafka]
via GitHub
Re: [PR] KAFKA-19465: feat(connect): add value.type config to InsertHeader SMT [kafka]
via GitHub
Re: [PR] KAFKA-19465: feat(connect): add value.type config to InsertHeader SMT [kafka]
via GitHub
Re: [PR] KAFKA-19465: feat(connect): add value.type config to InsertHeader SMT [kafka]
via GitHub
[PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
Re: [PR] KAFKA-20169: Support static membership for Kafka Streams with the streams rebalance protocol at Client Side. [kafka]
via GitHub
[PR] KAFKA-19902: fix(consumer): use latest leader epoch when committing offsets [kafka]
via GitHub
Re: [PR] KAFKA-19902: fix(consumer): use latest leader epoch when committing offsets [kafka]
via GitHub
[PR] KAFKA-20688: Fix RocksDB memory leak [kafka]
via GitHub
Re: [PR] KAFKA-20688: Fix RocksDB memory leak [kafka]
via GitHub
Re: [PR] KAFKA-20688: Fix RocksDB memory leak [kafka]
via GitHub
Re: [PR] KAFKA-20688: Fix RocksDB memory leak [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families
Matthias J. Sax (Jira)
[PR] MINOR: Add 4.2.1 to system tests [kafka]
via GitHub
Re: [PR] MINOR: Add 4.2.1 to system tests [kafka]
via GitHub
[jira] [Assigned] (KAFKA-14405) Log a warning when users attempt to set a config controlled by Streams
Gavin Wang (Jira)
[jira] [Updated] (KAFKA-20197) Add headers support to StreamPartitioner
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20197) Add headers support to StreamPartitioner
Uladzislau Blok (Jira)
[jira] [Commented] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families
Nilesh Kumar (Jira)
[jira] [Updated] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families
Lucy Liu (Jira)
[jira] [Created] (KAFKA-20688) Memory leak in RocksDBTimestampedStoreWithHeaders.openRocksDB when probing column families
Lucy Liu (Jira)
Re: [PR] KAFKA-20167 Introduce CloseOptions.DEFAULT for Kafka Streams [kafka]
via GitHub
Re: [PR] KAFKA-20167 Introduce CloseOptions.DEFAULT for Kafka Streams [kafka]
via GitHub
[jira] [Created] (KAFKA-20687) Consider improving unused chunks reuse when no data written
Lianet Magrans (Jira)
[PR] MINOR: Add release related paths to .gitignore [kafka]
via GitHub
Re: [PR] MINOR: Add release related paths to .gitignore [kafka]
via GitHub
[PR] KAFKA-20623: DeleteGroups extension for streams group topology description plugin (3/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: DeleteGroups extension for streams group topology description plugin (3/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: DeleteGroups extension for streams group topology description plugin (3/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: DeleteGroups extension for streams group topology description plugin (3/3) [kafka]
via GitHub
[PR] KAFKA-19753: Fix duplicated topic metrics in FetchMetricsManager for topic names containing dots [kafka]
via GitHub
Re: [PR] KAFKA-19753: Fix duplicated topic metrics in FetchMetricsManager for topic names containing dots [kafka]
via GitHub
[PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Update RPC for streams group topology description plugin (2/3) [kafka]
via GitHub
[PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka]
via GitHub
Re: [PR] KAFKA-20623: Heartbeat extension for streams group topology description plugin (1/3) [kafka]
via GitHub
[PR] docs: add Oxford comma in README.md project list [kafka]
via GitHub
Re: [PR] docs: add Oxford comma in README.md project list [kafka]
via GitHub
Re: [PR] docs: add Oxford comma in README.md project list [kafka]
via GitHub
[jira] [Assigned] (KAFKA-16235) auto commit still causes delays due to retriable UNKNOWN_TOPIC_OR_PARTITION
Nilesh Kumar (Jira)
[jira] [Resolved] (KAFKA-20640) Consumer group accepts new classic members when migration policy is disabled
David Jacot (Jira)
[jira] [Commented] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids
Luke Chen (Jira)
[jira] [Resolved] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids
Luke Chen (Jira)
[jira] [Reopened] (KAFKA-20617) kafka-storage.sh should disallow invalid cluster ids
Luke Chen (Jira)
Re: [PR] KAFKA-20497: Add TimeOrderedCachingWindowStore#readOnly [kafka]
via GitHub
Re: [PR] KAFKA-20497: Add TimeOrderedCachingWindowStore#readOnly [kafka]
via GitHub
Re: [PR] KAFKA-20497: Add TimeOrderedCachingWindowStore#readOnly [kafka]
via GitHub
Re: [PR] KAFKA-20490: Add transaction buffer framework [kafka]
via GitHub
Re: [PR] KAFKA-20490: Add transaction buffer framework [kafka]
via GitHub
Re: [PR] KAFKA-20490: Add transaction buffer framework [kafka]
via GitHub
Re: [PR] KAFKA-20490: Add transaction buffer framework [kafka]
via GitHub
[PR] MINOR: Fix spotless import order violation in OAuthBearerValidatorCallbackHandlerTest [kafka]
via GitHub
Re: [PR] MINOR: Fix spotless import order violation in OAuthBearerValidatorCallbackHandlerTest [kafka]
via GitHub
[jira] (KAFKA-20685) EOS: checkpoint file written at restoration completion persists through RUNNING, state wipe is skipped after unclean crash
Eswarar Siva (Jira)
[PR] KAFKA-20685: Delete checkpoint file when EOS task completes restoration (4.2) [kafka]
via GitHub
Re: [PR] KAFKA-20685: Delete checkpoint file when EOS task completes restoration (4.2) [kafka]
via GitHub
Re: [PR] KAFKA-20685: Delete checkpoint file when EOS task completes restoration (4.2) [kafka]
via GitHub
Re: [PR] KAFKA-10549: Add topic ID support to ListOffsets - client (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-10549: Add topic ID support to ListOffsets - client (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20201: Connect Transforms: SchemaUtil.copySchemaBasics(Schema) does not preserve keySchema and valueSchema for MAP type [kafka]
via GitHub
Re: [PR] KAFKA-20201: Connect Transforms: SchemaUtil.copySchemaBasics(Schema) does not preserve keySchema and valueSchema for MAP type [kafka]
via GitHub
Re: [PR] Add explicit least-privilege permissions to GitHub workflows [kafka]
via GitHub
Re: [PR] Kip 1340 poc [kafka]
via GitHub
Re: [PR] Enhance MirrorMaker 2 with Fault Tolerance Capabilities [kafka]
via GitHub
Re: [PR] Enhance MirrorMaker 2 with Fault Tolerance Capabilities [kafka]
via GitHub
Re: [PR] Enhance MirrorMaker 2 with Fault Tolerance Capabilities [kafka]
via GitHub
Re: [PR] KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and s… [kafka]
via GitHub
Re: [PR] KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and s… [kafka]
via GitHub
Re: [PR] KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and s… [kafka]
via GitHub
Re: [PR] KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and s… [kafka]
via GitHub
Re: [PR] KAFKA-20646: Use Locale.ROOT in String.format() calls in tools/ and s… [kafka]
via GitHub
[PR] KAFKA-20553: Eliminate the dependencies on sourceSets.test.output for connect:runtime [kafka]
via GitHub
Re: [PR] KAFKA-20553: Eliminate the dependencies on sourceSets.test.output for connect:runtime [kafka]
via GitHub
Earlier messages
Later messages