jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] KAFKA-19939 Extending ProcessExceptionalHandler for Global Thread [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extending ProcessExceptionalHandler for Global Thread [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionalHandler for Global Thread [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionalHandler for Global Thread [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionalHandler for Global Thread [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionalHandler for Global Thread [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
Re: [PR] KAFKA-19939 Extend ProcessingExceptionHandler to GlobalKTable processors [kafka]
via GitHub
[jira] [Commented] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode
Mark Paget (Jira)
[jira] [Commented] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode
Bertalan Kondrat (Jira)
[jira] [Commented] (KAFKA-19652) Consumer throughput drops by 10 times with Kafka v3.9.0 in ZK mode
M Paget (Jira)
[PR] MINOR: miss spelling [kafka]
via GitHub
Re: [PR] MINOR: miss spelling [kafka]
via GitHub
Re: [PR] MINOR: miss spelling [kafka]
via GitHub
Re: [PR] MINOR: miss spelling [kafka]
via GitHub
[PR] MINOR: Update KafkaStreams.start JavaDocs [kafka]
via GitHub
Re: [PR] MINOR: Update KafkaStreams.start JavaDocs [kafka]
via GitHub
Re: [PR] MINOR: Fix race conditions in KafkaStreams when topic is missing. [kafka]
via GitHub
Re: [PR] MINOR: Fix race conditions in KafkaStreams when topic is missing. [kafka]
via GitHub
[PR] Revert "MINOR Use pull_request instead of pull_request_target (#21530)" [kafka]
via GitHub
Re: [PR] Revert "MINOR Use pull_request instead of pull_request_target (#21530)" [kafka]
via GitHub
[PR] DO NOT MERGE testing labeler [kafka]
via GitHub
Re: [PR] DO NOT MERGE testing labeler [kafka]
via GitHub
[PR] MINOR Use pull_request instead of pull_request_target [kafka]
via GitHub
Re: [PR] MINOR Use pull_request instead of pull_request_target [kafka]
via GitHub
Re: [PR] MINOR Use pull_request instead of pull_request_target [kafka]
via GitHub
Re: [PR] MINOR Use pull_request instead of pull_request_target [kafka]
via GitHub
[jira] [Commented] (KAFKA-20203) setFlushListener should pass record.headers() instead of empty headers
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-20203) setFlushListener should pass record.headers() instead of empty headers
Nishant Kumar (Jira)
[jira] [Resolved] (KAFKA-20159) Group configuration for share.delivery.count.limit
Andrew Schofield (Jira)
[PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (N/N) [kafka]
via GitHub
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (N/N) [kafka]
via GitHub
[jira] [Created] (KAFKA-20203) setFlushListener should pass record.headers() instead of empty headers
TengYao Chi (Jira)
[jira] [Updated] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders
TengYao Chi (Jira)
[jira] [Updated] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders
TengYao Chi (Jira)
[jira] [Updated] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders
Alieh Saeedi (Jira)
[jira] [Created] (KAFKA-20202) Verify existing IQv2 methods for MeteredTimestampedWindowStoreWithHeaders
TengYao Chi (Jira)
[jira] [Commented] (KAFKA-20155) Implement lazy deserialization mechanism
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-20155) Implement lazy deserialization mechanism
Alieh Saeedi (Jira)
[jira] [Commented] (KAFKA-20155) Implement lazy deserialization mechanism
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-19709) Add LegacyCheckpointingStateStore
Bill Bejeck (Jira)
[jira] [Assigned] (KAFKA-19709) Add LegacyCheckpointingStateStore
Bill Bejeck (Jira)
[jira] [Updated] (KAFKA-19434) Move logic for state store initiation to StreamThread handover
Matthias J. Sax (Jira)
[PR] MINOR: Use wildcard generics instead of defensive copies in TaskManager [kafka]
via GitHub
Re: [PR] MINOR: Use wildcard generics instead of defensive copies in TaskManager [kafka]
via GitHub
Re: [PR] MINOR: Use wildcard generics instead of defensive copies in TaskManager [kafka]
via GitHub
Re: [PR] MINOR: Use wildcard generics instead of defensive copies in TaskManager [kafka]
via GitHub
[PR] HOTFIX:Add headers to log change method, some variables final, update… [kafka]
via GitHub
Re: [PR] HOTFIX: Add headers to log change method, some variables final, update… [kafka]
via GitHub
Re: [PR] HOTFIX: Add headers to log change method, some variables final, update… [kafka]
via GitHub
[PR] MINOR: Cache endpoint-to-partitions computation in streams group heartbeat [kafka]
via GitHub
Re: [PR] MINOR: Cache endpoint-to-partitions computation in streams group heartbeat [kafka]
via GitHub
Re: [PR] MINOR: Cache endpoint-to-partitions computation in streams group heartbeat [kafka]
via GitHub
Re: [PR] MINOR: Cache endpoint-to-partitions computation in streams group heartbeat [kafka]
via GitHub
Re: [PR] MINOR: Cache endpoint-to-partitions computation in streams group heartbeat [kafka]
via GitHub
Re: [PR] MINOR: Cache endpoint-to-partitions computation in streams group heartbeat [kafka]
via GitHub
Re: [PR] MINOR: Cache endpoint-to-partitions computation in streams group heartbeat [kafka]
via GitHub
Re: [PR] MINOR: Cache endpoint-to-partitions computation in streams group heartbeat [kafka]
via GitHub
Re: [PR] MINOR: Cache endpoint-to-partitions computation in streams group heartbeat [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19434) Move logic for state store initiation to StreamThread handover
Bill Bejeck (Jira)
[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
[jira] [Updated] (KAFKA-20201) Connect Transforms: SchemaUtil.copySchemaBasics(Schema) does not preserve keySchema and valueSchema for MAP type
Chaemin Lee (Jira)
[PR] Fix typos in protocol.md [kafka]
via GitHub
Re: [PR] MINOR: Fix typos in protocol.md [kafka]
via GitHub
[PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
Re: [PR] KAFKA-19774: Cleanups for KIP-1066 [kafka]
via GitHub
[PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
Re: [PR] KAFKA-19740: Deprecate group.coordinator.rebalance.protocols config (KIP-1237) [kafka]
via GitHub
[PR] Gqmelo/replication factor policy [kafka]
via GitHub
Re: [PR] Gqmelo/replication factor policy [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20200) Broken link to CVE list
Chia-Ping Tsai (Jira)
[PR] MINOR: refactor Segment [kafka]
via GitHub
Re: [PR] MINOR: refactor Kafka Streams "segment" code [kafka]
via GitHub
Re: [PR] MINOR Metrics: use String.intern() to reduce duplicate metric names and tags [kafka]
via GitHub
Re: [PR] MINOR Metrics: use String.intern() to reduce duplicate metric names and tags [kafka]
via GitHub
Re: [PR] KAFKA-18995: Add bidirectional replication check [kafka]
via GitHub
Re: [PR] KAFKA-18995: Add bidirectional replication check [kafka]
via GitHub
Re: [PR] KAFKA-17218: let kafka-consumer-groups handle describe groups with deleted topics [kafka]
via GitHub
Re: [PR] KAFKA-17218: let kafka-consumer-groups handle describe groups with deleted topics [kafka]
via GitHub
Re: [PR] KAFKA-18647: Clarify Windows support in Quick Start Guide [kafka]
via GitHub
Re: [PR] KAFKA-18647: Clarify Windows support in Quick Start Guide [kafka]
via GitHub
[jira] [Commented] (KAFKA-20200) Broken link to CVE list
ASF GitHub Bot (Jira)
[jira] [Commented] (KAFKA-20200) Broken link to CVE list
ASF GitHub Bot (Jira)
[jira] [Commented] (KAFKA-20200) Broken link to CVE list
ASF GitHub Bot (Jira)
[jira] [Commented] (KAFKA-20200) Broken link to CVE list
ASF GitHub Bot (Jira)
[jira] [Commented] (KAFKA-20200) Broken link to CVE list
ASF GitHub Bot (Jira)
[jira] [Assigned] (KAFKA-20200) Broken link to CVE list
Chia-Yi Chiu (Jira)
[jira] [Created] (KAFKA-20201) Connect Transforms: SchemaUtil.copySchemaBasics(Schema) does not preserve keySchema and valueSchema for MAP type
Chaemin Lee (Jira)
[jira] [Assigned] (KAFKA-17789) State updater stuck when starting with empty state folder
Guang Zhao (Jira)
[jira] [Assigned] (KAFKA-17789) State updater stuck when starting with empty state folder
Guang Zhao (Jira)
[PR] KAFKA-20192 Fix brittle logic in ReconfigurableQuorumIntegrationTest [kafka]
via GitHub
Re: [PR] KAFKA-20192 Fix brittle logic in ReconfigurableQuorumIntegrationTest [kafka]
via GitHub
Re: [PR] KAFKA-20192 Fix brittle logic in ReconfigurableQuorumIntegrationTest [kafka]
via GitHub
Re: [PR] KAFKA-20192 Fix brittle logic in ReconfigurableQuorumIntegrationTest [kafka]
via GitHub
Re: [PR] KAFKA-20192 Fix brittle logic in ReconfigurableQuorumIntegrationTest [kafka]
via GitHub
Re: [PR] KAFKA-20192 Fix brittle logic in ReconfigurableQuorumIntegrationTest [kafka]
via GitHub
[jira] [Commented] (KAFKA-19558) kafka-consumer-groups.sh --describe --all-groups command times out on large clusters with many consumer groups
Akhilesh Chaganti (Jira)
[jira] [Commented] (KAFKA-19558) kafka-consumer-groups.sh --describe --all-groups command times out on large clusters with many consumer groups
Mark Paget (Jira)
[jira] [Created] (KAFKA-20200) Broken link to CVE list
Mickael Maison (Jira)
[jira] [Created] (KAFKA-20199) Evaluate whether BrokerId metrics tag should be renamed to NodeId or split by role
Ming-Yen Chung (Jira)
[jira] [Updated] (KAFKA-9920) Fix NetworkDegradeTest.test_rate test error
Viktor Somogyi-Vass (Jira)
[jira] [Updated] (KAFKA-9920) Fix NetworkDegradeTest.test_rate test error
Viktor Somogyi-Vass (Jira)
[jira] [Updated] (KAFKA-9920) Fix NetworkDegradeTest.test_rate test error
Viktor Somogyi-Vass (Jira)
[jira] [Updated] (KAFKA-9920) Fix NetworkDegradeTest.test_rate test error
Viktor Somogyi-Vass (Jira)
[PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka]
via GitHub
Re: [PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka]
via GitHub
Re: [PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka]
via GitHub
Re: [PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka]
via GitHub
Re: [PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka]
via GitHub
Re: [PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka]
via GitHub
Re: [PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka]
via GitHub
Re: [PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka]
via GitHub
Re: [PR] KAFKA-20184: Change jose4j from compileOnly to implementation in clients module [kafka]
via GitHub
[jira] [Created] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky
Jochen Rauschenbusch (Jira)
[jira] [Resolved] (KAFKA-19774) Mechanism to cordon brokers and log directories
Mickael Maison (Jira)
[jira] [Updated] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky
Jochen Rauschenbusch (Jira)
[jira] [Updated] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky
Jochen Rauschenbusch (Jira)
[jira] [Updated] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky
Jochen Rauschenbusch (Jira)
[jira] [Updated] (KAFKA-20198) StickyPartitionAssignor with group protocol classic is not acting sticky
Jochen Rauschenbusch (Jira)
[jira] [Created] (KAFKA-20197) Add headers support to StreamPartitioner
Uladzislau Blok (Jira)
[jira] [Assigned] (KAFKA-20197) Add headers support to StreamPartitioner
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-20197) Add headers support to StreamPartitioner
Uladzislau Blok (Jira)
[jira] [Updated] (KAFKA-20197) Add headers support to StreamPartitioner
Uladzislau Blok (Jira)
Re: [PR] KAFKA-13392 Resolve Timeout Exception triggering reassign partitions with --bootstrap-server option [kafka]
via GitHub
Re: [PR] KAFKA-13392 Resolve Timeout Exception triggering reassign partitions with --bootstrap-server option [kafka]
via GitHub
Re: [PR] KAFKA-13392 Resolve Timeout Exception triggering reassign partitions with --bootstrap-server option [kafka]
via GitHub
[PR] KAFKA-20153: Upgrade ducktape from 0.12 to 0.13 [kafka]
via GitHub
Re: [PR] KAFKA-20153: Upgrade ducktape from 0.12 to 0.13 [kafka]
via GitHub
Re: [PR] KAFKA-20153: Upgrade ducktape from 0.12 to 0.13 [kafka]
via GitHub
Re: [PR] KAFKA-20153: Upgrade ducktape from 0.12 to 0.13 [kafka]
via GitHub
Re: [PR] KAFKA-20153: Upgrade ducktape from 0.12 to 0.13 [kafka]
via GitHub
Re: [PR] KAFKA-20153: Upgrade ducktape from 0.12 to 0.13 [kafka]
via GitHub
[jira] [Updated] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics
Nick Guo (Jira)
[jira] [Updated] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-20196) Deprecate Yammer-based metrics in `GroupCoordinatorMetrics` and add equivalent Kafka Metrics
Nick Guo (Jira)
Re: [PR] KAFKA-19619: Refactore DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation [kafka]
via GitHub
Re: [PR] KAFKA-19619: Refactore DescribeTopicPartitionsRequestHandler: Improve readability and add code documentation [kafka]
via GitHub
Re: [PR] KAFKA-17103: MockClient tight loops when no metadata is present in KafkaProducerTest [kafka]
via GitHub
[PR] streams: remove unnecessary empty statement in ProcessingExceptionHan… [kafka]
via GitHub
Re: [PR] streams: remove unnecessary empty statement in ProcessingExceptionHan… [kafka]
via GitHub
Re: [PR] streams: remove unnecessary empty statement in ProcessingExceptionHan… [kafka]
via GitHub
Re: [PR] MINOR: remove unnecessary empty statement in ProcessingExceptionHandler [kafka]
via GitHub
Re: [PR] MINOR: remove unnecessary empty statement in ProcessingExceptionHandler [kafka]
via GitHub
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
Re: [PR] KAFKA-20079: Improve Connect configurable components discoverability [kafka]
via GitHub
Earlier messages
Later messages