Messages by Thread
-
[jira] [Assigned] (KAFKA-18707) Move KRaftMetadataCachePublisher to metadata module
Mickael Maison (Jira)
-
Re: [PR] KAFKA-6786: Remove additional configs in StreamsBrokerDownResilienceTest [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20742) Start offset for newly initialized share partitions should be 0
Sushant Mahajan (Jira)
-
[PR] KAFKA-19122: updateClusterMetadata receives multiples PartitionInfo [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20746) NPE in MetadataCache#toCluster
Kuan Po Tseng (Jira)
-
[jira] [Commented] (KAFKA-20746) NPE in MetadataCache#toCluster
Kuan Po Tseng (Jira)
-
[jira] [Created] (KAFKA-20746) NPE in MetadataCache#toCluster
Luke Chen (Jira)
-
[PR] MINOR: Fix typos in documentation [kafka]
via GitHub
-
Re: [PR] WIP: Removing WindowedSerializer interface from public class implementations [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20745) add tests for OffsetMapTest to verify different hash algorithms?
Chia-Ping Tsai (Jira)
-
[jira] [Assigned] (KAFKA-20745) add tests for OffsetMapTest to verify different hash algorithms?
Jimmy Wang (Jira)
-
Re: [PR] MINOR: Move BrokerReconfigurable to server module [kafka]
via GitHub
-
[PR] MINOR: Add EdgeML-Broker scaffold for edge AI [kafka]
via GitHub
-
Re: [PR] KAFKA-20292 [5/N]: Add TargetAssignmentRecordsBuilder [kafka]
via GitHub
-
Re: [PR] MINOR: Add doc for configuration parameters to keep the format consistent [kafka]
via GitHub
-
Re: [PR] (WIP-PoC) KIP-1271: Allow to Store Record Headers in State Stores [kafka]
via GitHub
-
[PR] ci: pin GitHub Actions to full commit SHAs [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-12227) Add method "Producer#send" to return CompletionStage instead of Future
Ming-Yen Chung (Jira)
-
[PR] KAFKA-20292 [4/N]: Lift member updates out of streams TargetAssignmentBuilder [kafka]
via GitHub
-
[PR] KAFKA-20720: Lower level for client log on self-healing share session… [kafka]
via GitHub
-
[PR] docs: update 'Testing a Streams Application' example code [kafka]
via GitHub
-
Re: [PR] fix: insecure default behavior in SslClientAuth.forConfig [kafka]
via GitHub
-
Re: [PR] KAFKA-19952: Don't upload to remote if the segment had already expired according to remote retention configure [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20744) Add back `rack.aware.assignment.tags` config
Matthias J. Sax (Jira)
-
[jira] [Commented] (KAFKA-20116) Support HA assignor in the streams rebalance protocol
Matthias J. Sax (Jira)
-
[jira] [Created] (KAFKA-20744) Add back `rack.aware.assignment.tags` config
Ziyun Fu (Jira)
-
[jira] [Assigned] (KAFKA-20744) Add back `rack.aware.assignment.tags` config
Ziyun Fu (Jira)
-
[PR] KAFKA-20297: Deprecate Time-accepting constructors in KafkaStreams and Metrics [kafka]
via GitHub
-
[PR] Added support for dynamic SSL certificate reload for controllers [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20743) Disallow negative leaderEpoch in readState and leaderEpoch/stateEpoch in writeState share coordinator.
Apoorv Mittal (Jira)
-
[PR] MINOR: Add 4.3.1 to system tests [kafka]
via GitHub
-
[jira] [Updated] (KAFKA-20739) Transaction coordinator rejects InitProducerId v6 recovery with KeepPreparedTxn=true
Bill Bejeck (Jira)
-
[PR] KAFKA-18707: Move KRaftMetadataCachePublisher to metadata module [kafka]
via GitHub
-
Re: [PR] KAFKA-13152: Add input.buffer.max.bytes based on KIP-770 [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20701) KIP drafting, publication, discussion, vote
Jess Jin (Jira)
-
[jira] [Resolved] (KAFKA-20727) Update Kafka Streams system tests for transactional stores
Bill Bejeck (Jira)
-
[PR] KAFKA-20743: Restrict sentinel leader and state epoch in share coord. [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20743) Disallow negative leaderEpoch in readState and leaderEpoch/stateEpoch in writeState share coordinator.
Sushant Mahajan (Jira)
-
[jira] [Commented] (KAFKA-19491) Add documentation for missing AsyncKafkaConsumer metrics
RITIK KUMAR JAISWAL (Jira)
-
[PR] KAFKA-19491 CONSUMER protocol metrics documentation [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20742) Start offset for newly initialized share partitions should be 0
Sushant Mahajan (Jira)
-
[PR] KAFKA-20490: Track committed and uncommitted RocksDB Positions [kafka]
via GitHub
-
[PR] KAFKA-20500: Add isolation-level reads to versioned stores [kafka]
via GitHub
-
[PR] KAFKA-20499: Add isolation-level reads to in-memory stores [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20734) Offline partition can cause loss of transaction markers
Wang Xiaoqing (Jira)
-
[PR] KAFKA-20734: Return noNode for known partitions without endpoints [kafka]
via GitHub
-
Re: [PR] MINOR: Rewrite SaslClientsWithInvalidCredentialsTest and rename to ConsumerGroupCommandSaslAuthenticationTest [kafka]
via GitHub
-
[PR] MINOR: Fix ShareGroupCommandTest reset-offsets tests passing invalid --from-file scope combination [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20495) Transactional support for InMemorySessionStore and InMemoryWindowStore
Bill Bejeck (Jira)
-
[PR] KAFKA-20726: Don't reuse the BufferSupplier in kraft state machine [kafka]
via GitHub
-
[jira] [Resolved] (KAFKA-20498) RocksDBStore readOnly implementation
Bill Bejeck (Jira)
-
[jira] [Updated] (KAFKA-20740) It is possible to have more than one concurrent voter change operation
Jira
-
[jira] [Assigned] (KAFKA-16517) Do not decode metadata records in the internal kraft partition listener
tony tang (Jira)
-
[jira] [Assigned] (KAFKA-20740) It is possible to have more hand one concurrent voter change operation
Jonah Hooper (Jira)
-
[jira] [Updated] (KAFKA-20706) Implement query type 4 (TimestampedWindowRangeQueryWithHeaders)
Jess Jin (Jira)
-
[jira] [Updated] (KAFKA-20705) Implement query type 3 (TimestampedWindowKeyQueryWithHeaders)
Jess Jin (Jira)
-
[PR] KAFKA-20741: Add ReadOnlyRecord IQv2 result type (KIP-1356) [kafka]
via GitHub
-
[jira] [Created] (KAFKA-20741) Add ReadOnlyRecord Interface
Jess Jin (Jira)
-
[jira] [Resolved] (KAFKA-20702) PoC PR of query type 1 (TimestampedKeyQueryWithHeaders)
Jess Jin (Jira)
-
[jira] [Created] (KAFKA-20740) It is possible to have more hand one concurrent voter change operation
Jira
-
Re: [PR] KAFKA-20292 [1/N]: Prepare to split TargetAssignmentBuilders [kafka]
via GitHub
-
[PR] MINOR: Follow-up KAFKA-20696 [kafka]
via GitHub
-
[PR] KAFKA-20553: Remove Scala dependency from streams:integration-tests [kafka]
via GitHub
-
[jira] [Assigned] (KAFKA-20739) Transaction coordinator rejects InitProducerId v6 recovery with KeepPreparedTxn=true
Shekhar Prasad Rajak (Jira)
-
[jira] [Created] (KAFKA-20739) Transaction coordinator rejects InitProducerId v6 recovery with KeepPreparedTxn=true
Shekhar Prasad Rajak (Jira)
-
[jira] [Created] (KAFKA-20738) Producer 2PC init sets v6-only InitProducerId fields but request builder caps version at v5
Shekhar Prasad Rajak (Jira)
-
[PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub
-
Re: [PR] KAFKA-19871: Add a TopologyTestDriverBuilder, deprecate old constructors [kafka]
via GitHub