jira
Thread
Date
Earlier messages
Messages by Thread
Re: [PR] [WIP] Draft proposal for adding retries to timed out KS EOS commit requests [kafka]
via GitHub
Re: [PR] KAFKA-18870 Implement describeDelegationToken for controller [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20166) Ensure KafkaConsumer.assign() triggers immediate auto-commit regardless of interval
Eric Chang (Jira)
[jira] [Commented] (KAFKA-20166) Ensure KafkaConsumer.assign() triggers immediate auto-commit regardless of interval
Eric Chang (Jira)
[jira] [Created] (KAFKA-20166) Ensure KafkaConsumer.assign() triggers immediate auto-commit regardless of interval
Chia-Ping Tsai (Jira)
Re: [PR] KAFKA-19931 Align broker and controller behavior for the Admin.incrementalAlterConfigs API [kafka]
via GitHub
[PR] MINOR: use correct deserialize method in ValueTimestampHeaders [kafka]
via GitHub
[PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
Re: [PR] MINOR: rename TaskRegistry methods to better reflect their purpose. [kafka]
via GitHub
[jira] [Resolved] (KAFKA-19833) Reduce code duplication in nullable protocol types
Jun Rao (Jira)
Re: [PR] KAFKA-19833: Reduce code duplication in nullable protocol types [kafka]
via GitHub
[jira] [Updated] (KAFKA-20155) Implement lazy deserialization mechanism
Matthias J. Sax (Jira)
[jira] [Created] (KAFKA-20165) Consumer poll may fail with unrecoverable KafkaException if topic not in metadata when fetching committed offsets
Lianet Magrans (Jira)
[PR] MINOR: Replace FutureUtils.failedFuture with CompletableFuture.failedFuture [kafka]
via GitHub
Re: [PR] MINOR: Replace FutureUtils.failedFuture with CompletableFuture.failedFuture [kafka]
via GitHub
[PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (2/N) [kafka]
via GitHub
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (2/N) [kafka]
via GitHub
[jira] [Created] (KAFKA-20164) Add Kraft layer support for snapshots with metadata records via new handeLoadBootstrap
John Mannooparambil (Jira)
[jira] [Assigned] (KAFKA-20153) Upgrade ducktape from 0.12 to 0.13
Nick Guo (Jira)
[jira] [Assigned] (KAFKA-20152) Remove unused CoordinatorMetrics#registry
Nick Guo (Jira)
[PR] KAFKA-20137: Add javadoc to public APIs in org.apache.kafka.clients.producer [kafka]
via GitHub
[PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders(1/N) [kafka]
via GitHub
Re: [PR] KAFKA-20132: Implement TimestampedKeyValueStoreWithHeaders (1/N) [kafka]
via GitHub
[PR] KAFKA-20163: Missing MM2 default exclude configs [kafka]
via GitHub
Re: [PR] KAFKA-20163: Missing MM2 default exclude configs [kafka]
via GitHub
Re: [PR] KAFKA-20163: Missing MM2 default exclude configs [kafka]
via GitHub
[jira] [Updated] (KAFKA-20163) Missing MM2 default exclude configs
Federico Valeri (Jira)
[jira] [Comment Edited] (KAFKA-19992) Allow to configure max memory for restore path
Jira
[jira] [Updated] (KAFKA-20110) KAFKA-20110 Fix generated doc and Javadoc for dynamic configs
Maros Orsak (Jira)
[PR] Implement content checksum verification in Lz4BlockInputS… [kafka]
via GitHub
[jira] [Created] (KAFKA-20163) MM2: Add log.message.timestamp.before.max.ms and log.message.timestamp.after.max.ms to default config.properties.exclude
Federico Valeri (Jira)
[jira] [Updated] (KAFKA-20163) MM2: Add log.message.timestamp.before.max.ms and log.message.timestamp.after.max.ms to default config.properties.exclude
Federico Valeri (Jira)
[jira] [Updated] (KAFKA-20163) MM2: Add log.message.timestamp.before.max.ms and log.message.timestamp.after.max.ms to default config.properties.exclude
Federico Valeri (Jira)
[PR] KAFKA-19361: Document that `mapKey` does not break the serialization compatibility [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20162) Validation and enforcement of group configurations
Andrew Schofield (Jira)
[jira] [Assigned] (KAFKA-20161) Group configuration for share.renew.acknowledge.enable
Andrew Schofield (Jira)
[jira] [Assigned] (KAFKA-20160) Group configuration for share.partition.max.record.locks
Andrew Schofield (Jira)
[jira] [Commented] (KAFKA-20148) Data Loss Risk When Disabling Remote Storage Due to Race Condition
Kamal Chandraprakash (Jira)
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
Re: [PR] KAFKA-16366: Refactor KTable source optimization [kafka]
via GitHub
[jira] [Commented] (KAFKA-20162) Validation and enforcement of group configurations
majialong (Jira)
[jira] [Commented] (KAFKA-20162) Validation and enforcement of group configurations
Andrew Schofield (Jira)
[PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
Re: [PR] MINOR-restructuring: Relocated PartitionMetadataClient to server-common [kafka]
via GitHub
[jira] [Updated] (KAFKA-19831) Failures in the StateUpdater thread may lead to inability to shut down a stream thread
Matthias J. Sax (Jira)
[PR] KAFKA-10863: Convert ControRecordType schema to use auto-generated protocol [kafka]
via GitHub
Re: [PR] KAFKA-10863: Convert ControRecordType schema to use auto-generated protocol [kafka]
via GitHub
Re: [PR] KAFKA-10863: Convert ControRecordType schema to use auto-generated protocol [kafka]
via GitHub
[jira] [Updated] (KAFKA-19833) Reduce code duplication in nullable protocol types
Lan Ding (Jira)
[jira] [Updated] (KAFKA-19833) Reduce code duplication in nullable protocol types
Lan Ding (Jira)
[jira] [Commented] (KAFKA-20161) Group configuration for share.renew.acknowledge.enable
Lan Ding (Jira)
[jira] [Commented] (KAFKA-20161) Group configuration for share.renew.acknowledge.enable
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-19984) Throttle-related dynamic configurations should not have the `isReadOnly` flag
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-20160) Group configuration for share.partition.max.record.locks
Ming-Yen Chung (Jira)
[jira] [Commented] (KAFKA-20160) Group configuration for share.partition.max.record.locks
Andrew Schofield (Jira)
[PR] KAFKA-19831: Improved error handling in DefaultStateUpdater. (#20767) [kafka]
via GitHub
Re: [PR] KAFKA-19831: Improved error handling in DefaultStateUpdater. (#20767) [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20159) Group configuration for share.delivery.count.limit
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-20142) Add javadoc to org.apache.kafka.streams module
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Genseric Ghiro (Jira)
[jira] [Updated] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Genseric Ghiro (Jira)
[jira] [Resolved] (KAFKA-20129) Server error caused by appending/subtracting a non-existent config key
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-20159) Group configuration for share.delivery.count.limit
TaiJuWu (Jira)
[jira] [Commented] (KAFKA-20159) Group configuration for share.delivery.count.limit
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-20162) Validation and enforcement of group configurations
Andrew Schofield (Jira)
[jira] [Created] (KAFKA-20161) Group configuration for share.renew.acknowledge.enable
Andrew Schofield (Jira)
[PR] MINOR: Ensure CoordinatorRuntime does not throw synchronous exceptions when returning futures [kafka]
via GitHub
Re: [PR] MINOR: Ensure CoordinatorRuntime does not throw synchronous exceptions when returning futures [kafka]
via GitHub
Re: [PR] MINOR: Ensure CoordinatorRuntime does not throw synchronous exceptions when returning futures [kafka]
via GitHub
[jira] [Created] (KAFKA-20160) Group configuration for share.partition.max.record.locks
Andrew Schofield (Jira)
[jira] [Updated] (KAFKA-20077) Producer using transactions v1 could hang on flush upon retriable failures adding partitions to tx
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-20159) Group configuration for share.delivery.count.limit
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-20115) Group coordinator fails to unload metadata when no longer leader or follower
David Jacot (Jira)
[jira] [Created] (KAFKA-20158) Implement SessionStoreWithHeaders
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20158) Implement SessionStoreWithHeaders
Alieh Saeedi (Jira)
[jira] [Updated] (KAFKA-20158) Implement SessionStoreWithHeaders
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-20158) Implement SessionStoreWithHeaders
Alieh Saeedi (Jira)
[jira] [Created] (KAFKA-20157) Partition Size Percentage Metrics for Storage Monitoring
Manan Gupta (Jira)
[jira] [Assigned] (KAFKA-20156) Fix leaking *_DOC variables in All Configs
Jira
[jira] [Assigned] (KAFKA-20156) Fix leaking *_DOC variables in All Configs
majialong (Jira)
[PR] MINOR: Replace ConfiguredTopology with TopologyValidationResult [kafka]
via GitHub
[jira] [Updated] (KAFKA-20156) Fix leaking *_DOC variables in All Configs
Jira
[jira] [Updated] (KAFKA-20156) Fix leaking *_DOC variables in All Configs
Jira
[jira] [Created] (KAFKA-20156) Fix leaking *_DOC variables in All Configs
Jira
[jira] [Assigned] (KAFKA-20155) Implement lazy deserialization mechanism
TengYao Chi (Jira)
[jira] [Created] (KAFKA-20155) Implement lazy deserialization mechanism
TengYao Chi (Jira)
[jira] [Resolved] (KAFKA-20111) Describing group configs for pre-4.1 broker with later kafka-configs.sh fails
Chia-Ping Tsai (Jira)
[PR] MINOR: Document that REMAIN_IN_GROUP is ignored with streams protocol [kafka]
via GitHub
Re: [PR] MINOR: Document that REMAIN_IN_GROUP is ignored with streams protocol [kafka]
via GitHub
[PR] KAFKA-19914: Move AlterPartitionManager to server module [kafka]
via GitHub
[PR] MINOR: Fix SSL certificate verification failure in system test worker provisioning [kafka]
via GitHub
Re: [PR] MINOR: Fix SSL certificate verification failure in system test worker provisioning [kafka]
via GitHub
Re: [PR] MINOR: Fix SSL certificate verification failure in system test worker provisioning [kafka]
via GitHub
[jira] [Updated] (KAFKA-20111) Describing group configs for pre-4.1 broker with later kafka-configs.sh fails
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-20034) DeliveryCompleteCount should be 0 when share group offsets are altered.
Chirag Wadhwa (Jira)
Re: [PR] KAFKA-15358: Added QueuedReplicaToDirAssignments metric [kafka]
via GitHub
Re: [PR] KAFKA-15358: Added QueuedReplicaToDirAssignments metric [kafka]
via GitHub
Re: [PR] KAFKA-15358: Added QueuedReplicaToDirAssignments metric [kafka]
via GitHub
Re: [PR] KAFKA-15358: Added QueuedReplicaToDirAssignments metric [kafka]
via GitHub
[jira] [Commented] (KAFKA-20143) Add javadoc to org.apache.kafka.tools.api module
majialong (Jira)
[jira] [Commented] (KAFKA-20139) Add javadoc to org.apache.kafka.connect module
majialong (Jira)
[jira] [Assigned] (KAFKA-20143) Add javadoc to org.apache.kafka.tools.api module
Jira
[jira] [Assigned] (KAFKA-20139) Add javadoc to org.apache.kafka.connect module
Jira
[jira] [Assigned] (KAFKA-20141) Add javadoc to org.apache.kafka.server module
Jira
[jira] [Assigned] (KAFKA-20135) Add javadoc to org.apache.kafka.clients.admin module
Jira
[jira] [Assigned] (KAFKA-20138) Add javadoc to org.apache.kafka.common module
Jira
[jira] [Assigned] (KAFKA-20142) Add javadoc to org.apache.kafka.streams module
Jira
[PR] EN-20096 Adding rocksdb upgrade and downgrade system test [kafka]
via GitHub
Re: [PR] EN-20096 Adding rocksdb upgrade and downgrade system test [kafka]
via GitHub
Re: [PR] EN-20096 Adding rocksdb upgrade and downgrade system test [kafka]
via GitHub
Re: [PR] KAFKA-20096 Adding rocksdb upgrade and downgrade system test [kafka]
via GitHub
[jira] [Commented] (KAFKA-20154) Migrate Kakfa - client and non-client modules to Java 21(JDK 21)
Chia-Ping Tsai (Jira)
[jira] [Comment Edited] (KAFKA-20096) RocksDB compatibility not documented
Arpit Goyal (Jira)
[jira] [Commented] (KAFKA-19276) Compare assignment configuration only when assignment related configurations are updated
Uladzislau Blok (Jira)
[jira] [Comment Edited] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Young Joo Kim (Jira)
[jira] [Assigned] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Young Joo Kim (Jira)
[jira] [Commented] (KAFKA-20137) Add javadoc to org.apache.kafka.clients.producer
Young Joo Kim (Jira)
[PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
Re: [PR] KAFKA-20136: Add javadoc to public APIs in org.apache.kafka.clients.consumer module [kafka]
via GitHub
[jira] [Created] (KAFKA-20154) Migrate Kakfa - client and non-client modules to Java 21(JDK 21)
Sujay Hegde (Jira)
[jira] [Updated] (KAFKA-20151) Provide and execution Strategy for adding C4 diagram architecture
Sujay Hegde (Jira)
[jira] [Updated] (KAFKA-20150) Spike and explore usage of C4 diagram too like strcutrizer
Sujay Hegde (Jira)
[jira] [Updated] (KAFKA-20150) Spike and explore usage of C4 diagram too like structurizr
Sujay Hegde (Jira)
[jira] [Updated] (KAFKA-20150) Spike and explore usage of C4 diagram too like structurizr
Sujay Hegde (Jira)
[jira] [Updated] (KAFKA-20150) Spike and explore usage of C4 diagram too like structurizr
Sujay Hegde (Jira)
[PR] KAFKA-20150: Add Structurizr scaffolding for C4 Diagrams [kafka]
via GitHub
[jira] [Updated] (KAFKA-20150) Spike and explore usage of C4 diagram too like strcurtizer
Sujay Hegde (Jira)
[jira] [Assigned] (KAFKA-20150) Spike and explore usage of C4 diagram too like strcutizer
Sujay Hegde (Jira)
[PR] MINOR: Fix off-by-one in ShareCoordinatorShard snapshot update count [kafka]
via GitHub
[PR] MINOR: Fix Javadoc in coordinator-common [kafka]
via GitHub
Re: [PR] KAFKA-19687: MetaDataShell log error message for SNAPSHOT_HEADER and SNAPSHOT_FOOTER [kafka]
via GitHub
Re: [PR] KAFKA-19687: MetaDataShell log error message for SNAPSHOT_HEADER and SNAPSHOT_FOOTER [kafka]
via GitHub
[PR] KAFKA-20129: Fix server error when appending or subtracting a non-existent config key [kafka]
via GitHub
Re: [PR] KAFKA-20129: Fix server error when appending or subtracting a non-existent config key [kafka]
via GitHub
[jira] [Assigned] (KAFKA-20129) Server error caused by appending/subtracting a non-existent config key
Lan Ding (Jira)
[PR] KAFKA-20119: Clarify that `Consumer#unsubscribe` does not trigger auto-commit [kafka]
via GitHub
Re: [PR] KAFKA-20119: Clarify that `Consumer#unsubscribe` does not trigger auto-commit [kafka]
via GitHub
Re: [PR] KAFKA-20119: Clarify that `Consumer#unsubscribe` does not trigger auto-commit [kafka]
via GitHub
[jira] [Updated] (KAFKA-20119) Clarify that `Consumer#unsubscribe` does not trigger auto-commit
Matthias J. Sax (Jira)
[jira] [Commented] (KAFKA-19992) Allow to configure max memory for restore path
Jira
[jira] [Commented] (KAFKA-19657) Improve RebalanceProtocolMigrationIntegrationTest
Matthias J. Sax (Jira)
[jira] [Assigned] (KAFKA-20116) HA assignor in streams rebalance protocol
Matthias J. Sax (Jira)
[jira] [Updated] (KAFKA-20151) Provide and execution Startegy for adding C4 diagram architecture
Sujay Hegde (Jira)
[jira] [Assigned] (KAFKA-20151) Provide and execution Startegy for adding C4 diagram architecture
Sujay Hegde (Jira)
[jira] [Created] (KAFKA-20153) Upgrade ducktape from 0.12 to 0.13
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-20152) Remove unused CoordinatorMetrics#registry
Chia-Ping Tsai (Jira)
[jira] [Commented] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest
majialong (Jira)
[jira] [Assigned] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest
majialong (Jira)
[jira] [Created] (KAFKA-20151) Provide and execution Starategy for adding C4 diagram archietecture
Sujay Hegde (Jira)
[jira] [Created] (KAFKA-20150) Spike and explore usage of C4 diagram too like strcutizer
Sujay Hegde (Jira)
[jira] [Updated] (KAFKA-20149) C4 Architecture Diagram for Apache Kafka Ecosystem
Sujay Hegde (Jira)
[jira] [Created] (KAFKA-20149) C4 Architecture Diagram for Apache Kafka Ecosystem
Sujay Hegde (Jira)
[jira] [Updated] (KAFKA-20148) Data Loss Risk When Disabling Remote Storage Due to Race Condition
dyingjiecai (Jira)
[jira] [Created] (KAFKA-20148) Data Loss Risk When Disabling Remote Storage Due to Race Condition
dyingjiecai (Jira)
Re: [PR] Clarification of topic configuration 'retention.bytes' [kafka]
via GitHub
Re: [PR] Clarification of topic configuration 'retention.bytes' [kafka]
via GitHub
[jira] [Resolved] (KAFKA-15894) MessageConversionsTimeMs and TemporaryMemoryBytes may not be recorded correctly.
Chia-Ping Tsai (Jira)
[jira] [Assigned] (KAFKA-20146) Add CI job to detect dependency conflicts in setup.py
Ming-Yen Chung (Jira)
Re: [PR] KAFKA-19768: Update ci-complete to support branch 4.0 buildscan upload [kafka]
via GitHub
Re: [PR] KAFKA-19768: Update ci-complete to support branch 4.0 buildscan upload [kafka]
via GitHub
[jira] [Resolved] (KAFKA-20147) Add CI job to detect dependency conflicts in setup.py
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-20147) Add CI job to detect dependency conflicts in setup.py
Chia-Ping Tsai (Jira)
[jira] [Created] (KAFKA-20146) Add CI job to detect dependency conflicts in setup.py
Chia-Ping Tsai (Jira)
[PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
[PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
[PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
Re: [PR] KAFKA-19960: Close pending tasks on shutdown. (#21365) [kafka]
via GitHub
[jira] [Updated] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment
Lianet Magrans (Jira)
[jira] [Updated] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment
Lianet Magrans (Jira)
[jira] [Updated] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment
Lianet Magrans (Jira)
[jira] [Updated] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment
Lianet Magrans (Jira)
[jira] [Updated] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-20145) Improve consumer HB ack on unchanged target assignment
Lianet Magrans (Jira)
Earlier messages