dev  

Messages by Thread

• [jira] [Resolved] (KAFKA-18811) Allow passing the Consumer Configs to the AdminClientProperties for VerifiableShareConsumers Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-18936) Share fetch stuck when records are larger than fetch max bytes Apoorv Mittal (Jira)
• [jira] [Created] (KAFKA-18934) Consider making records in FetchResponse not nullable Ismael Juma (Jira)
• [jira] [Created] (KAFKA-18932) Remove partitionMaxBytes usage from brokers for share fetch requests Abhinav Dixit (Jira)
• [jira] [Created] (KAFKA-18931) Debug the case where kafka-share-groups.sh --describe --members does not match with the reality when share consumer is closed during broker outage Chirag Wadhwa (Jira)
• [jira] [Created] (KAFKA-18930) KRaft MigrationEvent won't retry when failing to write data to ZK Luke Chen (Jira)
• [jira] [Resolved] (KAFKA-18246) Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18929) Log a warning when a time retention based segment has a future timestamp Daniel Urban (Jira)
• [jira] [Reopened] (KAFKA-18246) Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18928) Support to dynamically change config for specific controller Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18927) Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0 Chia-Ping Tsai (Jira)
• Confluence permission for KIP Johnny Wang
  • Re: Confluence permission for KIP Bill Bejeck
  • Re: Confluence permission for KIP Johnny Wang
  • Re: Confluence permission for KIP Bruno Cadonna
• Protected Branches and Required Checks David Arthur
  • Re: Protected Branches and Required Checks Chia-Ping Tsai
  • Re: Protected Branches and Required Checks David Arthur
  • Re: Protected Branches and Required Checks David Arthur
  • Re: Protected Branches and Required Checks Chia-Ping Tsai
  • Re: Protected Branches and Required Checks Ismael Juma
  • Re: Protected Branches and Required Checks David Arthur
  • Re: Protected Branches and Required Checks David Arthur
  • Re: Protected Branches and Required Checks Ismael Juma
  • Re: Protected Branches and Required Checks David Arthur
  • Re: Protected Branches and Required Checks Ismael Juma
  • Re: Protected Branches and Required Checks David Arthur
• [jira] [Resolved] (KAFKA-14121) AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor Kuan Po Tseng (Jira)
• [jira] [Created] (KAFKA-18926) `KafkaPrincipalBuilder` should extend `KafkaPrincipalSerde` Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18804) Remove slf4j warning when using tool script. Chia-Ping Tsai (Jira)
• [VOTE] 4.0.0 RC1 David Jacot
  • Re: [VOTE] 4.0.0 RC1 David Jacot
  • Re: [VOTE] 4.0.0 RC1 Jun Rao
  • Re: [VOTE] 4.0.0 RC1 David Jacot
  • Re: [VOTE] 4.0.0 RC1 Jun Rao
• [jira] [Resolved] (KAFKA-18887) Implement Admin API extensions beyond list/describe group (delete group, offset-related APIs) Lucas Brutschy (Jira)
• [jira] [Created] (KAFKA-18925) Add streams groups support in `Admin.listGroups`. Lucas Brutschy (Jira)
• [jira] [Resolved] (KAFKA-18919) Clarify that KafkaPrincipalBuilder classes must also implement KafkaPrincipalSerde Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18882) Remove BaseKey, TxnKey, and UnknownKey Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-12903) Replace producer state entry with auto-generated protocol Deng Ziming (Jira)
• [jira] [Created] (KAFKA-18924) Running the storage module tests produces a storage/storage.log file Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-10864) Convert End Transaction Marker to use auto-generated protocal Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18886) add behavior change of CreateTopicPolicy and AlterConfigPolicy to zk2kraft Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18923) resource leak in RSM fetchIndex inputStream Luke Chen (Jira)
• [jira] [Created] (KAFKA-18922) RequestContext#principalSerde should not be optional as it is now always present Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18780) Extend RetriableException related exceptions Kaushik Raina (Jira)
• Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #227 Apache Jenkins Server
  • Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #228 Apache Jenkins Server
• [jira] [Created] (KAFKA-18921) Low CPU utilization during streams integration tests David Arthur (Jira)
• [jira] [Created] (KAFKA-18920) kafka-feature doesn't report the correct kraft.version Jira
• Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics Mickael Maison
  • Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics Mickael Maison
  • Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics Luke Chen
  • Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics 黃竣陽
  • Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics 黃竣陽
  • Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics Jun Rao
  • Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics Mickael Maison
  • Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics 黃竣陽
  • Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics Jun Rao
• [jira] [Created] (KAFKA-18919) Clarify that KafkaPrincipalBuilder classes must also implement KafkaPrincipalSerde Mickael Maison (Jira)
• [jira] [Resolved] (KAFKA-18876) 4.0 documentation improvement Chia-Ping Tsai (Jira)
• Community Over Code Asia Travel Assistance Applications now open! Mickael Maison
• [jira] [Resolved] (KAFKA-18916) Resolved regular expressions must update the group by topics data structure David Jacot (Jira)
• [DISCUSS] KIP-1117 Support keystore with multiple alias entries Rahul Nirgude
  • RE: [DISCUSS] KIP-1117 : Support keystore with multiple alias entries Rahul Nirgude
  • Re: [DISCUSS] KIP-1117 Support keystore with multiple alias entries Mickael Maison
  • RE: Re: [DISCUSS] KIP-1117 Support keystore with multiple alias entries Rahul Nirgude
  • RE: Re: [DISCUSS] KIP-1117 Support keystore with multiple alias entries Rahul Nirgude
• [jira] [Created] (KAFKA-18918) Share partition lock held for onComplete exception Apoorv Mittal (Jira)
• [jira] [Created] (KAFKA-18917) TransformValues with unnamed Materialized instance throws NPE Lucas Brutschy (Jira)
• [PR] Falkon SMS Kafka Usage [kafka-site] via GitHub
  • Re: [PR] Falkon SMS Kafka Usage [kafka-site] via GitHub
• [jira] [Created] (KAFKA-18916) Resolved regular expressions must update the group by topics data structure David Jacot (Jira)
• [jira] [Created] (KAFKA-18915) Migrate AdminClientRebootstrapTest to use new test infra Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18914) Migrate ConsumerRebootstrapTest to use new test infra Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18867) add tests to describe topic configs with empty name Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18844) Stale features information in QuorumController#registerBroker Jun Rao (Jira)
• [jira] [Resolved] (KAFKA-18878) Implement ShareSessionCache and DelayedShareFetchMetrics metrics for share fetch Apoorv Mittal (Jira)
• Re: [DISCUSS] KIP-896: Remove old client protocol API versions in Kafka 4.0 Jun Rao
  • Re: [DISCUSS] KIP-896: Remove old client protocol API versions in Kafka 4.0 Ismael Juma
  • Re: [DISCUSS] KIP-896: Remove old client protocol API versions in Kafka 4.0 Jun Rao
• [jira] [Created] (KAFKA-18913) Consider removing state-updater feature flag Matthias J. Sax (Jira)
• [jira] [Created] (KAFKA-18912) Failed test MetadataSchemaCheckerToolTest.testVerifyEvolutionGit on Trunk Lorcan (Jira)
• [jira] [Reopened] (KAFKA-18067) Kafka Streams can leak Producer client under EOS Bruno Cadonna (Jira)
• [jira] [Resolved] (KAFKA-18911) alterPartition gets stuck when getting out-of-date errors Luke Chen (Jira)
• [jira] [Created] (KAFKA-18911) alterPartition gets stuck when getting out-of-date errors Luke Chen (Jira)
• [jira] [Resolved] (KAFKA-18881) Document the ConsumerRecord as non-thread safe Chia-Ping Tsai (Jira)
• KIP-1117: Support keystore with multiple alias entries Rahul Nirgude
• [jira] [Created] (KAFKA-18910) Move kafka.utils.json to tool module Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18909) Move DynamicThreadPool to server module Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18907) add suitable error message when the appended value is too larger Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18908) the size of appended value can't be larger than Short.MAX_VALUE Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-17793) Improve kcontroller robustness against long delays Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18748) Run new integration tests separately in PRs Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18905) Avoid out of order sequence errors from multiple in-flight batches Sean Quah (Jira)
• [jira] [Resolved] (KAFKA-18880) Remove kafka.cluster.Broker and BrokerEndPointNotAvailableException Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-17981) add Integration test for ConfigCommand to add config `key=[val1,val2]` Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-17039) KIP-919 supports for `unregisterBroker` Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18908) the size of appended value can't be larger than Short.MAX_VALUE Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18907) add suitable error message when the appended value is too larger Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18868) add the "default value" explanation to the docs of num.replica.alter.log.dirs.threads Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18906) Upgrade to Junit 5.13 and apply ParameterizedClass Chia-Ping Tsai (Jira)
• Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #224 Apache Jenkins Server
• APACHE KAFKA DOCUMENTATION oshione esiemokhai
• [jira] [Resolved] (KAFKA-18669) Connector is restarted before it is started Anil Dasari (Jira)
• [jira] [Resolved] (KAFKA-18864) remove the Evolving tag from stable public interfaces Jun Rao (Jira)
• [jira] [Created] (KAFKA-18904) Listing of configs for dynamically created resources is mysterious Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-18903) Use curl + jq in update-cache.sh David Arthur (Jira)
• [jira] [Resolved] (KAFKA-18734) Implement share partition metrics for share fetch Apoorv Mittal (Jira)
• Kafka Producer Configuration Optimization for Production giri mungi
• [jira] [Created] (KAFKA-18902) Experiment with ShareConsumer option to throw on poll if there are unacked records Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-18901) Improve redistribution of share group SimpleAssignor Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-18899) Limit retry time for ShareConsumer.commitAsync Andrew Schofield (Jira)
• [jira] [Created] (KAFKA-18900) Create a consumer config to select between implicit and explicit acknowledgement Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-18522) Limit fetch records batches as per acquired records Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-18657) Flaky SharePartitionManagerTest Andrew Schofield (Jira)
• [jira] [Resolved] (KAFKA-18860) Clarify the KRaft missing feature Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18898) 4.0 Upgrade docs rendering below other versions David Arthur (Jira)
• [jira] [Created] (KAFKA-18891) Add support for RemoteLogMetadataManager and RemoteStorageManager Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18897) Add support for SslEngineFactory Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18896) Add support for Login Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18895) Add support for AuthenticateCallbackHandler Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18894) Add support for ConfigProvider Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18893) Add support for ReplicaSelector Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18892) Add support for ClientQuotaCallback Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18890) Add support for CreateTopicPolicy and AlterConfigPolicy Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18889) Make records in ShareFetchResponse non-nullable Apoorv Mittal (Jira)
• [jira] [Created] (KAFKA-18888) Add support for Authorizer Mickael Maison (Jira)
• Metadata requests for subset of partitions Michał Łowicki
  • Re: Metadata requests for subset of partitions Kirk True
  • Re: Metadata requests for subset of partitions Michał Łowicki
  • Re: Metadata requests for subset of partitions Stanislav Kozlovski
  • Re: Metadata requests for subset of partitions Michał Łowicki
  • Re: Metadata requests for subset of partitions Stanislav Kozlovski
  • Re: Metadata requests for subset of partitions Michał Łowicki
• [jira] [Created] (KAFKA-18887) Implement Admin API extensions beyond list/describe group (delete group, offset-related APIs) Alieh Saeedi (Jira)
• Proposal: Improving PR Review Process Nelson B.
  • Re: Proposal: Improving PR Review Process David Arthur
• [jira] [Created] (KAFKA-18886) add behavior change of CreateTopicPolicy and AlterConfigPolicy to zk2kraft Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18885) document the behavioral differences between ZooKeeper and KRaft Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18884) Move TransactionMetadata to transaction-coordinator module PoAn Yang (Jira)
• [jira] [Created] (KAFKA-18883) Move TransactionLog to transaction-coordinator module PoAn Yang (Jira)
• [jira] [Created] (KAFKA-18882) Move BaseKey, TxnKey, and UnknownKey to transaction-coordinator module Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18471) Race conditions when accessing RecordHeader data Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18881) Document the ConsumerRecord as non-thread safe Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18880) Remove kafka.cluster.Broker and BrokerEndPointNotAvailableException Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18849) add "strict min ISR" to the docs of "min.insync.replicas" Chia-Ping Tsai (Jira)
• [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Sebastien Viale
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Sophie Blee-Goldman
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Bruno Cadonna
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Sebastien Viale
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Bill Bejeck
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Sophie Blee-Goldman
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Lucas Brutschy
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Sophie Blee-Goldman
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Bruno Cadonna
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Bill Bejeck
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Sophie Blee-Goldman
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Sebastien Viale
  • Re: [DISCUSS] KIP-1138: Clean up TopologyConfig and API for supplying configs needed by the topology Sophie Blee-Goldman
• [jira] [Resolved] (KAFKA-18850) Fix the docs of org.apache.kafka.automatic.config.providers Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18879) Formatter for share group specific records in __consumer_offsets Sushant Mahajan (Jira)
• [jira] [Resolved] (KAFKA-18757) Create full-function SimpleAssignor to match KIP-932 description Abhinav Dixit (Jira)
• Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #222 Apache Jenkins Server
• [jira] [Resolved] (KAFKA-18869) add remote storage threads to "Updating Thread Configs" section Chia-Ping Tsai (Jira)
• [jira] [Resolved] (KAFKA-18875) KRaft controller does not retry registration if the first attempt times out TaiJuWu (Jira)
• [jira] [Created] (KAFKA-18878) Implement share session cache metrics for share fetch Apoorv Mittal (Jira)
• [jira] [Resolved] (KAFKA-18863) Runtime additions for connector multiversioning. Greg Harris (Jira)
• [jira] [Created] (KAFKA-18877) an mechanism to find cases where we accessed variables from the wrong thread Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18876) 4.0 documentation improvement Jun Rao (Jira)
• [jira] [Created] (KAFKA-18874) KRaft controller does not retry registration if the first attempt times out Daniel Fonai (Jira)
• [jira] [Created] (KAFKA-18875) KRaft controller does not retry registration if the first attempt times out Daniel Fonai (Jira)
• [jira] [Created] (KAFKA-18873) Incorrect error message for max.in.flight.requests.per.connection when using transactional producer. Eslam Mohamed (Jira)
• [jira] [Created] (KAFKA-18872) Convert StressTestLog and TestLinearWriteSpeed to jmh benchmarks Mickael Maison (Jira)
• [jira] [Created] (KAFKA-18871) KRaft migration rollback causes downtime Daniel Urban (Jira)
• [jira] [Created] (KAFKA-18870) implement describeDelegationToken for controller Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18869) add remote storage threads to "Updating Thread Configs" section Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18868) add the "default value" explanation to the docs of num.replica.alter.log.dirs.threads Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18867) add tests to describe topic configs with empty name Chia-Ping Tsai (Jira)
• [jira] [Created] (KAFKA-18866) JDK23: UnsupportedOperationException: getSubject is supported only if a security manager is allowed Christian Habermehl (Jira)
• [jira] [Created] (KAFKA-18865) Improve KRaft handling of kraft.version Jira
• [jira] [Created] (KAFKA-18864) remove the Evolving tag from public interfaces in org.apache.kafka.server.log.remote.storage Jun Rao (Jira)
• [jira] [Created] (KAFKA-18863) Runtime additions for connector multiversioning. Snehashis Pal (Jira)
• [PR] MINOR Fix the URL for matomo [kafka-site] via GitHub
  • Re: [PR] MINOR Fix the URL for matomo [kafka-site] via GitHub
  • Re: [PR] MINOR Fix the URL for matomo [kafka-site] via GitHub
  • Re: [PR] MINOR Fix the URL for matomo [kafka-site] via GitHub
• [jira] [Created] (KAFKA-18862) Review testHeartbeatResponseOnErrorHandling duplicate logic in ShareHeartbeatRequestManagerTest Lianet Magrans (Jira)
• [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Paweł Szymczyk
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Kirk True
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Paweł Szymczyk
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Matthias J. Sax
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Kirk True
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Chia-Ping Tsai
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Ismael Juma
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Ismael Juma
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Matthias J. Sax
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Paweł Szymczyk
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Paweł Szymczyk
  • Re: [DISCUSS] KIP-1136: Make ConsumerGroupMetadata an interface Kirk True

• Earlier messages
• Later messages