jira
Thread
Date
Earlier messages
Later messages
Messages by Thread
Re: [PR] KAFKA-20297: move KafkaThread, ThreadUtils, ExponentialBackoff and ExponentialBackoffManager to internal [kafka]
via GitHub
[jira] [Commented] (KAFKA-20443) Move RequestChannel Requests/Responses to server module
Chia-Ping Tsai (Jira)
[PR] MINOR: Clarify components not considered for security issues [kafka]
via GitHub
Re: [PR] MINOR: Clarify components not considered for security issues [kafka]
via GitHub
Re: [PR] MINOR: Clarify components not considered for security issues [kafka]
via GitHub
Re: [PR] MINOR: Clarify components not considered for security issues [kafka]
via GitHub
Re: [PR] MINOR: Clarify components not considered for security issues [kafka]
via GitHub
Re: [PR] MINOR: Clarify components not considered for security issues [kafka]
via GitHub
[jira] [Created] (KAFKA-20443) Move RequestChannel Requests/Responses to server module
Mickael Maison (Jira)
[PR] KAFKA-20442: Update streams group assignment epoch when last member leaves [kafka]
via GitHub
Re: [PR] KAFKA-20442: Update streams group assignment epoch when last member leaves [kafka]
via GitHub
Re: [PR] KAFKA-20442: Update streams group assignment epoch when last member leaves [kafka]
via GitHub
Re: [PR] KAFKA-20442: Update streams group assignment epoch when last member leaves [kafka]
via GitHub
[PR] KAFKA-20442: Update consumer group assignment epoch when last member leaves [kafka]
via GitHub
Re: [PR] KAFKA-20442: Update consumer group assignment epoch when last member leaves [kafka]
via GitHub
Re: [PR] KAFKA-20442: Update consumer group assignment epoch when last member leaves [kafka]
via GitHub
[PR] KAFKA-20442: Update share group assignment epoch when last member leaves [kafka]
via GitHub
Re: [PR] KAFKA-20442: Update share group assignment epoch when last member leaves [kafka]
via GitHub
[jira] [Created] (KAFKA-20442) Consumer/Share/Streams group assignment epoch is not updated when the last member leaves
David Jacot (Jira)
[jira] [Created] (KAFKA-20441) Follow ups for KIP-1066
Mickael Maison (Jira)
[PR] MINOR: add clear description on torgdor [kafka]
via GitHub
Re: [PR] MINOR: add clear description on torgdor [kafka]
via GitHub
Re: [PR] MINOR: add clear description on torgdor [kafka]
via GitHub
Re: [PR] MINOR: add clear description on torgdor [kafka]
via GitHub
[jira] [Assigned] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"
Shashank (Jira)
Re: [PR] KAFKA-13152: Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes" [kafka]
via GitHub
Re: [PR] MINOR Clarified maximum length of COMPACT_STRING [kafka]
via GitHub
Re: [PR] KAFKA-20118: Improve the error message caused by normally moving replica [kafka]
via GitHub
[jira] [Reopened] (KAFKA-13499) Avoid restoring outdated records
Matthias J. Sax (Jira)
[jira] [Comment Edited] (KAFKA-20427) Controllers can't form quorum on restart when hostnames changes with dynamic quorum
Jira
[jira] [Comment Edited] (KAFKA-20427) Controllers can't form quorum on restart when hostnames changes with dynamic quorum
Federico Valeri (Jira)
[jira] [Comment Edited] (KAFKA-20427) Controllers can't form quorum on restart when hostnames changes with dynamic quorum
Jira
[jira] [Comment Edited] (KAFKA-20427) Controllers can't form quorum on restart when hostnames changes with dynamic quorum
Jira
[PR] MINOR: fix incorrect JavaDocs for headers-stores [kafka]
via GitHub
Re: [PR] MINOR: fix incorrect JavaDocs for headers-stores [kafka]
via GitHub
Re: [PR] MINOR: fix incorrect JavaDocs for headers-stores [kafka]
via GitHub
[jira] [Commented] (KAFKA-10844) groupBy without shuffling
Guang Zhao (Jira)
[jira] [Commented] (KAFKA-10844) groupBy without shuffling
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-15709) KRaft support in ServerStartupTest
Oscar Arismendi (Jira)
[jira] [Assigned] (KAFKA-20439) Allow to write dropped records in the DLQ
Daeho Kwon (Jira)
[jira] [Commented] (KAFKA-20438) Allow dropping "future" records
Arpit Goyal (Jira)
[jira] [Assigned] (KAFKA-20438) Allow dropping "future" records
Arpit Goyal (Jira)
[jira] [Assigned] (KAFKA-20438) Allow dropping "future" records
Arpit Goyal (Jira)
[jira] [Assigned] (KAFKA-20438) Allow dropping "future" records
Arpit Goyal (Jira)
[jira] [Comment Edited] (KAFKA-20437) Dynamic update of ssl.enabled.protocols does not seem to take effect
Daeho Kwon (Jira)
[PR] Bump pytest from 8.3.3 to 9.0.3 in /tests [kafka]
via GitHub
Re: [PR] MINOR: Bump pytest from 8.3.3 to 9.0.3 in /tests [kafka]
via GitHub
[jira] [Commented] (KAFKA-20437) Dynamic update of ssl.enabled.protocols does not seem to take effect
Daeho Kwon (Jira)
[jira] [Commented] (KAFKA-20439) Allow to write dropped records in the DLQ
Daeho Kwon (Jira)
[jira] [Commented] (KAFKA-20439) Allow to write dropped records in the DLQ
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-20439) Allow to write dropped records in the DLQ
Daeho Kwon (Jira)
[jira] [Updated] (KAFKA-20440) PEM certificate support should not depend on PKCS12
Jakub Scholz (Jira)
[PR] KAFKA-20440: Use default Keystore type instead of hardcoding PKCS12 keystore type [kafka]
via GitHub
[jira] [Created] (KAFKA-20440) PEM certificate support should not depend on PKCS12
Jakub Scholz (Jira)
[jira] [Assigned] (KAFKA-14405) Log a warning when users attempt to set a config controlled by Streams
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-14405) Log a warning when users attempt to set a config controlled by Streams
Arpit Goyal (Jira)
Re: [PR] KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams [kafka]
via GitHub
Re: [PR] KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams [kafka]
via GitHub
Re: [PR] KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20213) Review assignment updates in ShareConsumer from background reconciliations
Lianet Magrans (Jira)
[jira] [Assigned] (KAFKA-16799) NetworkClientDelegate is not backing off if the node is not found
Lianet Magrans (Jira)
[PR] MINOR: Improve formatting for streams compatibility matrix, and add 4.3.x [kafka]
via GitHub
[jira] [Created] (KAFKA-20439) Allow to write dropped records in the DLQ
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20438) Allow dropping "future" records
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-20438) Allow dropping "future" records
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-20437) Dynamic update of ssl.enabled.protocols does not seem to take effect
Jakub Scholz (Jira)
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
Re: [PR] KAFKA-19774: Mechanism to cordon log dirs (KIP-1066) [kafka]
via GitHub
[PR] MINOR: Clarify group.consumer.assignors doc about default assignor change [kafka]
via GitHub
Re: [PR] MINOR: Clarify group.consumer.assignors doc about default assignor change [kafka]
via GitHub
[jira] [Updated] (KAFKA-20275) API to set commit offsets without being subscribed
Kirk True (Jira)
[jira] [Assigned] (KAFKA-20232) KafkaConsumer#commitAsync throws unexpected WakeupException in awaitMetadataUpdate()
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-20434) Consumer group does not recompute assignment when static members rejoin with different assignor
David Jacot (Jira)
[jira] [Assigned] (KAFKA-13248) Class name mismatch for LoggerFactory.getLogger method in TimeOrderedWindowStoreBuilder.java
Evan Zhou (Jira)
[jira] [Assigned] (KAFKA-15768) StateQueryResult#getOnlyPartitionResult should not throw for FailedQueryResult
Evan Zhou (Jira)
[jira] [Assigned] (KAFKA-19688) Provide clean upgrade path from transformValues to processValues
TengYao Chi (Jira)
[jira] [Commented] (KAFKA-17178) Update KTable.transformValues to new Processor API
TengYao Chi (Jira)
[jira] [Assigned] (KAFKA-17178) Update KTable.transformValues to new Processor API
TengYao Chi (Jira)
[PR] KAFKA-19649: Document ListOffsets API v11 and follower fetch from tiered of… [kafka]
via GitHub
Re: [PR] KAFKA-19649: Document ListOffsets API v11 and follower fetch from tiered of… [kafka]
via GitHub
Re: [PR] KAFKA-19649: Document ListOffsets API v11 and follower fetch from tiered of… [kafka]
via GitHub
Re: [PR] KAFKA-19649: Document ListOffsets API v11 and follower fetch from tiered of… [kafka]
via GitHub
[jira] [Updated] (KAFKA-15370) Support Participation in 2PC (KIP-939)
Mickael Maison (Jira)
[jira] [Updated] (KAFKA-19649) Document List Offset changes in upgrade.html
Mickael Maison (Jira)
[PR] KAFKA-19414: Revert Remove 2PC public APIs [kafka]
via GitHub
Re: [PR] KAFKA-19414: Revert Remove 2PC public APIs [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
[jira] [Comment Edited] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
[jira] [Comment Edited] (KAFKA-20399) Implement VersionedKeyValueStoreWithHeaders
Alieh Saeedi (Jira)
[jira] [Commented] (KAFKA-19785) Two Kafka brokers were not active in 3 node cluster setup
Jerome Waibel (Jira)
[jira] [Updated] (KAFKA-20434) Consumer group does not recompute assignment when static members rejoin with different assignor
David Jacot (Jira)
[jira] [Updated] (KAFKA-20434) Consumer group does not recompute assignment when static members rejoin with different assignor
David Jacot (Jira)
[jira] [Updated] (KAFKA-20434) Consumer group does not recompute assignment when static members rejoin with different assignor
David Jacot (Jira)
[PR] KAFKA-20434: Consumer group does not recompute assignment when static members rejoin with a different server-side assignor [kafka]
via GitHub
Re: [PR] KAFKA-20434: Consumer group does not recompute assignment when static members rejoin with different assignor [kafka]
via GitHub
Re: [PR] KAFKA-20434: Consumer group does not recompute assignment when static members rejoin with different assignor [kafka]
via GitHub
Re: [PR] KAFKA-20434: Consumer group does not recompute assignment when static members rejoin with different assignor [kafka]
via GitHub
Re: [PR] KAFKA-20434: Consumer group does not recompute assignment when static members rejoin with different assignor [kafka]
via GitHub
Re: [PR] KAFKA-20434: Consumer group does not recompute assignment when static members rejoin with different assignor [kafka]
via GitHub
[PR] KAFKA-18812: Improve consumer API errors upon background thread failure [kafka]
via GitHub
Re: [PR] KAFKA-18812: Improve consumer API errors upon background thread failure [kafka]
via GitHub
Re: [PR] KAFKA-18812: Improve consumer API errors upon background thread failure [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20379) ducker-ak has no option to skip the gradlew systemTestLibs build step
Maros Orsak (Jira)
[PR] KAFKA-20379: ducker-ak has no option to skip the gradlew systemTestLibs build step [kafka]
via GitHub
Re: [PR] KAFKA-20379: ducker-ak has no option to skip the gradlew systemTestLibs build step [kafka]
via GitHub
Re: [PR] KAFKA-17207: Recreate config topic in Connect test to prevent thread … [kafka]
via GitHub
[jira] [Comment Edited] (KAFKA-16996) The leastLoadedNode() function in kafka-client may choose a faulty node during the consumer thread starting and meanwhile one of the KAFKA server node is dead.
Goufu (Jira)
Re: [PR] KAFKA-2321; Introduce CONTRIBUTING.md [kafka]
via GitHub
Re: [PR] KAFKA-2320; Test commit [kafka]
via GitHub
Re: [PR] MINOR: Fixed ConsumerRecord constructor javadoc [kafka]
via GitHub
Re: [PR] Adding rack-aware replication option. [kafka]
via GitHub
[jira] [Commented] (KAFKA-18836) Make ConsumerGroupMetadata an interface
Andrew Schofield (Jira)
[jira] [Assigned] (KAFKA-18836) Make ConsumerGroupMetadata an interface
Andrew Schofield (Jira)
[jira] [Commented] (KAFKA-19595) Add configuration validation option to Kafka server startup
Ayantika Sarkar (Jira)
[PR] KAFKA-19595 Added configuration validation option to Kafka server sta… [kafka]
via GitHub
Re: [PR] KAFKA-19595 Added configuration validation option to Kafka server sta… [kafka]
via GitHub
[PR] MINOR: Fix arguments in trivy scan [kafka]
via GitHub
Re: [PR] MINOR: Fix arguments in trivy scan [kafka]
via GitHub
Re: [PR] MINOR: Fix arguments in trivy scan [kafka]
via GitHub
[PR] MINOR: Fix release.py to remove SNAPSHOT in version.py [kafka]
via GitHub
Re: [PR] MINOR: Fix release.py to remove SNAPSHOT in version.py [kafka]
via GitHub
Re: [PR] MINOR: Fix release.py to remove SNAPSHOT in version.py [kafka]
via GitHub
Re: [PR] MINOR: Delegate version updates to Gradle in release script [kafka]
via GitHub
Re: [PR] MINOR: Delegate version updates to Gradle in release script [kafka]
via GitHub
Re: [PR] MINOR: Delegate version updates to Gradle in release script [kafka]
via GitHub
[PR] [POC] KAFKA-20171: Kafka Streams use topic ids. (other version) [kafka]
via GitHub
Re: [PR] [POC] KAFKA-20171: Kafka Streams use topic ids. (other version) [kafka]
via GitHub
[PR] [POC] KAFKA-20171: Kafka Streams use topic ids. (other version) [kafka]
via GitHub
[PR] KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller [kafka]
via GitHub
Re: [PR] KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller [kafka]
via GitHub
Re: [PR] KAFKA-19123 the buffer of forwarded request should be released after receiving the reponse from controller [kafka]
via GitHub
Re: [PR] KAFKA-19470 Avoid creating loggers repeatedly to affect the performance of request processing [kafka]
via GitHub
Re: [PR] KAFKA-19470 Avoid creating loggers repeatedly to affect the performance of request processing [kafka]
via GitHub
Re: [PR] MINOR: add unit test for TransactionLog.readTxnRecordKey [kafka]
via GitHub
[jira] [Updated] (KAFKA-20436) Implement KIP-1318: Model Context Protocol (MCP) Server for Apache Kafka
vaquar khan (Jira)
[jira] [Created] (KAFKA-20436) Implement KIP-1318: Model Context Protocol (MCP) Server for Apache Kafka
vaquar khan (Jira)
[PR] MINOR: Move KafkaMetricsGroupTest from Scala to Java [kafka]
via GitHub
Re: [PR] MINOR: Move KafkaMetricsGroupTest from Scala to Java [kafka]
via GitHub
Re: [PR] MINOR: Move KafkaMetricsGroupTest from Scala to Java [kafka]
via GitHub
[jira] [Resolved] (KAFKA-16211) Inconsistent config values in CreateTopicsResult and DescribeConfigsResult
Ming-Yen Chung (Jira)
[PR] MINOR: code cleanup group coordinator [kafka]
via GitHub
[PR] MINOR: code cleanup in server [kafka]
via GitHub
Re: [PR] MINOR: code cleanup in server [kafka]
via GitHub
Re: [PR] MINOR: code cleanup in server [kafka]
via GitHub
[PR] KAFKA-20182: Remove removeUnusedImports and upgrade spotless to 8.4.0 [kafka]
via GitHub
Re: [PR] KAFKA-20182: Remove removeUnusedImports and upgrade spotless to 8.4.0 [kafka]
via GitHub
[jira] [Commented] (KAFKA-19686) Trigger Docker image builds in release script
Muralidhar Basani (Jira)
Re: [PR] KAFKA-18053 Clean up topology config [kafka]
via GitHub
Re: [PR] KAFKA-18053 Clean up topology config [kafka]
via GitHub
Re: [PR] KAFKA-20430 Add configuration to control internal topic creation in Kafka Connect [kafka]
via GitHub
Re: [PR] KAFKA-20430 Add configuration to control internal topic creation in Kafka Connect [kafka]
via GitHub
[PR] MINOR: Change trivy action [kafka]
via GitHub
Re: [PR] MINOR: Change trivy action [kafka]
via GitHub
Re: [PR] MINOR: Change trivy action [kafka]
via GitHub
Re: [PR] MINOR: Change trivy action [kafka]
via GitHub
Re: [PR] MINOR: Change trivy action [kafka]
via GitHub
[jira] [Commented] (KAFKA-20034) DeliveryCompleteCount should be 0 when share group offsets are altered.
PoAn Yang (Jira)
[PR] Adding sasl_plain docker compose examples [kafka]
via GitHub
Re: [PR] KAFKA-20419 : docker - Adding sasl_plain docker compose examples [kafka]
via GitHub
Re: [PR] KAFKA-20419 : docker - Adding sasl_plain docker compose examples [kafka]
via GitHub
Re: [PR] KAFKA-20419 : docker - Adding sasl_plain docker compose examples [kafka]
via GitHub
Re: [PR] KAFKA-20419 : docker - Adding sasl_plain docker compose examples [kafka]
via GitHub
[PR] MINOR: fix the Custom Exception Handler Implementation example. [kafka]
via GitHub
Re: [PR] MINOR: fix the Custom Exception Handler Implementation example. [kafka]
via GitHub
Re: [PR] MINOR: fix the Custom Exception Handler Implementation example. [kafka]
via GitHub
[PR] MINOR: Various code cleanups in server [kafka]
via GitHub
Re: [PR] MINOR: Various code cleanups in server [kafka]
via GitHub
Re: [PR] MINOR: Various code cleanups in server [kafka]
via GitHub
[jira] [Updated] (KAFKA-20379) ducker-ak has no option to skip the gradlew systemTestLibs build step
Maros Orsak (Jira)
Re: [PR] KAFKA-20245: DLQ share group client REJECT ack records. [2/N] [kafka]
via GitHub
Re: [PR] KAFKA-20245: DLQ share group client REJECT ack records. [2/N] [kafka]
via GitHub
Re: [PR] KAFKA-20245: DLQ share group client REJECT ack records. [2/N] [kafka]
via GitHub
Re: [PR] KAFKA-20245: DLQ share group client REJECT ack records. [2/N] [kafka]
via GitHub
Re: [PR] KAFKA-20245: DLQ share group client REJECT ack records. [2/N] [kafka]
via GitHub
[jira] [Updated] (KAFKA-20431) ConsumerGroupDescribe API does not return partitions being revoked
David Jacot (Jira)
[jira] [Created] (KAFKA-20435) Move LogManagerTest to storage module
Mickael Maison (Jira)
[jira] [Created] (KAFKA-20434) Consumer group does not recompute assignment when static members rejoin with a different server-side assignor
David Jacot (Jira)
[PR] Revert "KAFKA-18652: Add `task.offset.interval.ms` config (#21737)" [kafka]
via GitHub
Earlier messages
Later messages