jira
Thread
Date
Later messages
Messages by Thread
Re: [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka]
via GitHub
Re: [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka]
via GitHub
Re: [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka]
via GitHub
Re: [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka]
via GitHub
Re: [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka]
via GitHub
Re: [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka]
via GitHub
Re: [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka]
via GitHub
Re: [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka]
via GitHub
Re: [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka]
via GitHub
Re: [PR] KAFKA-20289: Fix DescribeConfigs to correctly resolve broker synonyms for group configs [kafka]
via GitHub
[PR] MINOR: Use getAbsolutePath in LocalLog#exception [kafka]
via GitHub
Re: [PR] MINOR: Use getAbsolutePath in LocalLog#exception [kafka]
via GitHub
[jira] [Commented] (KAFKA-20193) Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed
Nishant Kumar (Jira)
[jira] [Commented] (KAFKA-20193) Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed
Nishant Kumar (Jira)
[jira] [Commented] (KAFKA-20193) Remove `static <T> T value(...)` method from ValueTimestampHeadersDeserializer if not needed
Matthias J. Sax (Jira)
[PR] MINOR: Move TerseFailure to server-common [kafka]
via GitHub
Re: [PR] MINOR: Move TerseFailure to server-common [kafka]
via GitHub
Re: [PR] MINOR: Move TerseFailure to server-common [kafka]
via GitHub
Re: [PR] MINOR: Move TerseFailure to server-common [kafka]
via GitHub
Re: [PR] MINOR: Move TerseFailure to server-common [kafka]
via GitHub
Re: [PR] MINOR: Move TerseFailure to server-common [kafka]
via GitHub
Re: [PR] MINOR: Move TerseFailure to server-common [kafka]
via GitHub
[jira] [Resolved] (KAFKA-14487) Move LogManager to storage module
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-14487: Move LogManager to storage module [kafka]
via GitHub
Re: [PR] KAFKA-14487: Move LogManager to storage module [kafka]
via GitHub
Re: [PR] KAFKA-14487: Move LogManager to storage module [kafka]
via GitHub
Re: [PR] KAFKA-14487: Move LogManager to storage module [kafka]
via GitHub
Re: [PR] KAFKA-14487: Move LogManager to storage module [kafka]
via GitHub
Re: [PR] KAFKA-14487: Move LogManager to storage module [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20216) Jetty 12 requires slf4j 2
Ming-Yen Chung (Jira)
[jira] [Commented] (KAFKA-20216) Jetty 12 requires slf4j 2
Ming-Yen Chung (Jira)
[jira] [Comment Edited] (KAFKA-20334) Consider to update KStream-KStream join to use plain-value-header-window stores
PoAn Yang (Jira)
[jira] [Commented] (KAFKA-20334) Consider to update KStream-KStream join to use plain-value-header-window stores
PoAn Yang (Jira)
[jira] [Commented] (KAFKA-20334) Consider to update KStream-KStream join to use plain-value-header-window stores
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-20334) Consider to update KStream-KStream join to use plain-value-header-window stores
PoAn Yang (Jira)
Re: [PR] KAFKA-20361 : Fix LazyDownConversionRecordsTest in using zlib-ng [kafka]
via GitHub
Re: [PR] KAFKA-20361 : Fix LazyDownConversionRecordsTest in using zlib-ng [kafka]
via GitHub
Re: [PR] KAFKA-20361 : Fix LazyDownConversionRecordsTest in using zlib-ng [kafka]
via GitHub
Re: [PR] KAFKA-20361 : Fix LazyDownConversionRecordsTest in using zlib-ng [kafka]
via GitHub
Re: [PR] KAFKA-20361 : Fix LazyDownConversionRecordsTest in using zlib-ng [kafka]
via GitHub
Re: [PR] KAFKA-20328 : Adding missing test files - streams headers [kafka]
via GitHub
[jira] [Commented] (KAFKA-19958) Race condition between OAuthBearerSaslClientCallbackHandler and ExpiringCredentialRefreshingLogin.reLogin
luman (Jira)
[jira] [Commented] (KAFKA-19958) Race condition between OAuthBearerSaslClientCallbackHandler and ExpiringCredentialRefreshingLogin.reLogin
Mickael Maison (Jira)
[jira] [Commented] (KAFKA-19958) Race condition between OAuthBearerSaslClientCallbackHandler and ExpiringCredentialRefreshingLogin.reLogin
Shekhar Prasad Rajak (Jira)
Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka]
via GitHub
Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka]
via GitHub
Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka]
via GitHub
Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka]
via GitHub
Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka]
via GitHub
Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka]
via GitHub
Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka]
via GitHub
Re: [PR] KAFKA-19893: Reduce tiered storage redundancy with delayed upload (KIP-1241) [kafka]
via GitHub
Re: [PR] KAFKA-20346: LogCleaner#cleaners should be thread-safe [kafka]
via GitHub
Re: [PR] KAFKA-20346: LogCleaner#cleaners should be thread-safe [kafka]
via GitHub
Re: [PR] KAFKA-20346: LogCleaner#cleaners should be thread-safe [kafka]
via GitHub
Re: [PR] KAFKA-20346: LogCleaner#cleaners should be thread-safe [kafka]
via GitHub
Re: [PR] Feat/mm2 fault tolerance [kafka]
via GitHub
Re: [PR] KAFKA-20297: move ImplicitLinkedHash, ByteUtils from utils to internals [kafka]
via GitHub
Re: [PR] KAFKA-20297: move ImplicitLinkedHash, ByteUtils from utils to internals [kafka]
via GitHub
Re: [PR] KAFKA-20297: move ImplicitLinkedHash, ByteUtils from utils to internals [kafka]
via GitHub
Re: [PR] KAFKA-20297: Cleanup `org.apache.kafka.common.utils.CollectionUtils` [kafka]
via GitHub
Re: [PR] KAFKA-20297: Cleanup `org.apache.kafka.common.utils.CollectionUtils` [kafka]
via GitHub
Re: [PR] KAFKA-20297: Cleanup `org.apache.kafka.common.utils.CollectionUtils` [kafka]
via GitHub
[PR] KAFKA-19308: Improve OAuth layer unit test coverage based on code cov… [kafka]
via GitHub
Re: [PR] KAFKA-19308: Improve OAuth layer unit test coverage based on code cov… [kafka]
via GitHub
Re: [PR] KAFKA-19308: Improve OAuth layer unit test coverage based on code cov… [kafka]
via GitHub
Re: [PR] KAFKA-19308: Improve OAuth layer unit test coverage based on code cov… [kafka]
via GitHub
[jira] [Commented] (KAFKA-20362) Rescue the Tired Reviewer: Auto-fill PR Reviewers
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-20362) Rescue the Tired Reviewer: Auto-fill PR Reviewers
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-20362) Rescue the Tired Reviewer: Auto-fill PR Reviewers
Ming-Yen Chung (Jira)
[jira] [Commented] (KAFKA-20362) Rescue the Tired Reviewer: Auto-fill PR Reviewers
sanghyeok An (Jira)
Re: [PR] KAFKA-20359 : Update docker image with fully qualified name [kafka]
via GitHub
Re: [PR] KAFKA-20359 : Update docker image with fully qualified name [kafka]
via GitHub
Re: [PR] KAFKA-20359 : Update docker image with fully qualified name [kafka]
via GitHub
[jira] [Created] (KAFKA-20367) Support Share Groups (Queue Semantics) in Kafka Connect Sink Connectors
Shekhar Prasad Rajak (Jira)
[jira] [Updated] (KAFKA-20367) Support Share Groups (Queue Semantics) in Kafka Connect Sink Connectors
Shekhar Prasad Rajak (Jira)
[jira] [Resolved] (KAFKA-20310) nextProducerId and prevProducerId fields never persisted to transaction log
Justine Olshan (Jira)
Re: [PR] KAFKA-20310: Persist previousProducerId and nextProducerId in transaction log [kafka]
via GitHub
Re: [PR] KAFKA-20310: Persist previousProducerId and nextProducerId in transaction log [kafka]
via GitHub
Re: [PR] KAFKA-20310: Persist previousProducerId and nextProducerId in transaction log [kafka]
via GitHub
Re: [PR] KAFKA-20310: Persist previousProducerId and nextProducerId in transaction log [kafka]
via GitHub
[PR] fix: insecure default behavior in SslClientAuth.forConfig [kafka]
via GitHub
Re: [PR] fix: insecure default behavior in SslClientAuth.forConfig [kafka]
via GitHub
Re: [PR] fix: insecure default behavior in SslClientAuth.forConfig [kafka]
via GitHub
[jira] [Commented] (KAFKA-19469) Dead-letter queues for share groups
Shekhar Prasad Rajak (Jira)
[PR] KAFKA-20366: Add syntax highlighting across docs, excluding security and streams [kafka]
via GitHub
Re: [PR] KAFKA-20366: Add syntax highlighting across docs, excluding security and streams [kafka]
via GitHub
Re: [PR] KAFKA-20366: Add syntax highlighting across docs, excluding security and streams [kafka]
via GitHub
Re: [PR] KAFKA-20366: Add syntax highlighting across docs, excluding security and streams [kafka]
via GitHub
Re: [PR] KAFKA-20366: Add syntax highlighting across docs, excluding security and streams [kafka]
via GitHub
Re: [PR] KAFKA-20366: Add syntax highlighting across docs, excluding security and streams [kafka]
via GitHub
Re: [PR] KAFKA-20366: Add syntax highlighting across docs, excluding security and streams [kafka]
via GitHub
Re: [PR] KAFKA-20366: Add syntax highlighting across docs, excluding security and streams [kafka]
via GitHub
Re: [PR] KAFKA-20366: Add syntax highlighting across docs, excluding security and streams [kafka]
via GitHub
[jira] [Commented] (KAFKA-20205) Refactor serialization and deserialization code for *WithHeaders types
PoAn Yang (Jira)
[PR] KAFKA-20205: Use utils in TimestampedToHeadersWindowStoreAdapter [kafka]
via GitHub
Re: [PR] KAFKA-20205: Use utils in TimestampedToHeadersWindowStoreAdapter [kafka]
via GitHub
[jira] [Commented] (KAFKA-20366) Add syntax highlighting across documentation pages
gomudayya (Jira)
[jira] [Updated] (KAFKA-20366) Add syntax highlighting across documentation pages
gomudayya (Jira)
[jira] [Created] (KAFKA-20366) Add syntax highlighting across documentation pages
gomudayya (Jira)
[PR] KAFKA-20347: Fix metric leak and JMX tag order in ShareCoordinatorMetrics [kafka]
via GitHub
Re: [PR] KAFKA-20347: Fix metric leak and JMX tag order in ShareCoordinatorMetrics [kafka]
via GitHub
Re: [PR] KAFKA-20347: Fix metric leak and JMX tag order in ShareCoordinatorMetrics [kafka]
via GitHub
[jira] [Created] (KAFKA-20365) Flaky test tests/kafkatest/tests/core/consume_bench_test.py::ConsumeBenchTest.test_consume_bench
Ken Huang (Jira)
Re: [PR] KAFKA-19688: add new KStreams.process() overlaod [kafka]
via GitHub
Re: [PR] KAFKA-19688: add new KStreams.process() overlaod [kafka]
via GitHub
Re: [PR] MINOR: Add doc for configuration parameters to keep the format consistent [kafka]
via GitHub
Re: [PR] MINOR: Add doc for configuration parameters to keep the format consistent [kafka]
via GitHub
Re: [PR] KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path [kafka]
via GitHub
Re: [PR] KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path [kafka]
via GitHub
Re: [PR] KAFKA-15529: Fix race condition between isConsumed and position updates in AsyncKafkaConsumer fetch path [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
Re: [PR] KAFKA-17999: Fix flaky DynamicConnectionQuotaTest testDynamicConnectionQuota [kafka]
via GitHub
[jira] [Commented] (KAFKA-20171) Support regular expression topic patterns for streams groups
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-20171) Support regular expression topic patterns for streams groups
Lucas Brutschy (Jira)
[jira] [Commented] (KAFKA-20171) Support regular expression topic patterns for streams groups
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-20171) Support regular expression topic patterns for streams groups
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-20171) Support regular expression topic patterns for streams groups
Lucas Brutschy (Jira)
Re: [PR] KAFKA-18574: Sort quarantined test list by class_name and test_name [kafka]
via GitHub
Re: [PR] KAFKA-18574: Sort quarantined test list by class_name and test_name [kafka]
via GitHub
Re: [PR] KAFKA-18574: Sort quarantined test list by class_name and test_name [kafka]
via GitHub
Re: [PR] KAFKA-18574: Sort quarantined test list by class_name and test_name [kafka]
via GitHub
Re: [PR] KAFKA-18574: Sort quarantined test list by class_name and test_name [kafka]
via GitHub
[jira] [Updated] (KAFKA-16600) Periodically receive "Failed to transition to PENDING_SHUTDOWN, current state is PENDING_SHUTDOWN" during streams close
Kirk True (Jira)
[jira] [Commented] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable
sanghyeok An (Jira)
[jira] [Commented] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable
Arpit Goyal (Jira)
[jira] [Commented] (KAFKA-6686) Allow reading topic as KStream and GlobalKTable
sanghyeok An (Jira)
[jira] [Updated] (KAFKA-9195) Use Randomized State Directory Names in Streams System Tests
Bill Bejeck (Jira)
Re: [PR] KAFKA-9195: Use Randomized State Directory Names in Streams System Tests [kafka]
via GitHub
Re: [PR] KAFKA-9195: Use Randomized State Directory Names in Streams System Tests [kafka]
via GitHub
Re: [PR] KAFKA-9195: Use Randomized State Directory Names in Streams System Tests [kafka]
via GitHub
Re: [PR] KAFKA-20315: Add tests for single in-flight poll events in Async and Share consumers [kafka]
via GitHub
Re: [PR] KAFKA-20315: Add tests for single in-flight poll events in Async and Share consumers [kafka]
via GitHub
Re: [PR] KAFKA-20315: Add tests for single in-flight poll events in Async and Share consumers [kafka]
via GitHub
Re: [PR] KAFKA-20315: Add tests for single in-flight poll events in Async and Share consumers [kafka]
via GitHub
Re: [PR] KAFKA-20315: Add tests for single in-flight poll events in Async and Share consumers [kafka]
via GitHub
Re: [PR] KAFKA-20315: Add tests for single in-flight poll events in Async and Share consumers [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] KAFKA-20224: Refactor Streams iterator adapters to reduce duplication [kafka]
via GitHub
Re: [PR] MINOR: simplify window-byte-store-supplier [kafka]
via GitHub
Re: [PR] MINOR: simplify window-byte-store-supplier [kafka]
via GitHub
Re: [PR] MINOR: Remove boilerplate code from header serializer test [kafka]
via GitHub
Re: [PR] MINOR: Remove boilerplate code from header serializer test [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20279) Refactor `AbstractConfigurableStoreFactory#dslStoreFormat()`
Matthias J. Sax (Jira)
Re: [PR] KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory [kafka]
via GitHub
Re: [PR] KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory [kafka]
via GitHub
Re: [PR] KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory [kafka]
via GitHub
Re: [PR] KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory [kafka]
via GitHub
Re: [PR] KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory [kafka]
via GitHub
Re: [PR] KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory [kafka]
via GitHub
Re: [PR] KAFKA-20279: Refactor dslStoreFormat resolution into AbstractConfigurableStoreFactory [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20287) Verify (and potentially fix) if all CF handles (and other objects) are closed correctly
Matthias J. Sax (Jira)
Re: [PR] KAFKA-20287 : Fix CF handle leaks [kafka]
via GitHub
Re: [PR] KAFKA-20287 : Fix CF handle leaks [kafka]
via GitHub
Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka]
via GitHub
Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka]
via GitHub
Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka]
via GitHub
Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka]
via GitHub
Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka]
via GitHub
Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka]
via GitHub
Re: [PR] KAFKA-20036 Handle LogCleaner segment overflow caused by compression level changes [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20203) setFlushListener should pass record.headers() instead of empty headers
Matthias J. Sax (Jira)
Re: [PR] KAFKA-20203: setFlushListener should pass record.headers() instead of empty headers [kafka]
via GitHub
Re: [PR] KAFKA-20203: setFlushListener should pass record.headers() instead of empty headers [kafka]
via GitHub
Re: [PR] KAFKA-20203: setFlushListener should pass record.headers() instead of empty headers [kafka]
via GitHub
Re: [PR] KAFKA-20203: setFlushListener should pass record.headers() instead of empty headers [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
[PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
[PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
[PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
Re: [PR] KAFKA-13499: Avoid restoring outdated records [kafka]
via GitHub
[PR] KAFKA-19712: Commit OFFSET_UNKOWN when closing state stores and the offsets are not yet initialized [kafka]
via GitHub
Re: [PR] KAFKA-19712: Commit OFFSET_UNKOWN when closing state stores and the offsets are not yet initialized [kafka]
via GitHub
Re: [PR] KAFKA-19712: Commit OFFSET_UNKOWN when closing state stores and the offsets are not yet initialized [kafka]
via GitHub
Re: [PR] KAFKA-19712: Commit OFFSET_UNKOWN when closing state stores and the offsets are not yet initialized [kafka]
via GitHub
Re: [PR] KAFKA-19712: Commit OFFSET_UNKOWN when closing state stores and the offsets are not yet initialized [kafka]
via GitHub
Re: [PR] KAFKA-19712: Commit OFFSET_UNKOWN when closing state stores and the offsets are not yet initialized [kafka]
via GitHub
Re: [PR] MINOR: Fix headers in KTableMapValues and KTableTransformValues [kafka]
via GitHub
Re: [PR] MINOR: Fix headers in KTableMapValues and KTableTransformValues [kafka]
via GitHub
Re: [PR] MINOR: Fix headers in KTableMapValues and KTableTransformValues [kafka]
via GitHub
Later messages