dev
Thread
Date
Earlier messages
Later messages
Messages by Thread
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2632
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2633
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2634
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16189) Extend admin to support ConsumerGroupDescribe API
David Jacot (Jira)
[jira] [Resolved] (KAFKA-16168) Implement GroupCoordinator.onPartitionsDeleted
David Jacot (Jira)
[jira] [Created] (KAFKA-16214) No user info when SASL authentication failure
Luke Chen (Jira)
ZK vs KRaft benchmarking - latency differences?
Brebner, Paul
Re: ZK vs KRaft benchmarking - latency differences?
Doğuşcan Namal
Re: ZK vs KRaft benchmarking - latency differences?
Michael K. Edwards
Re: ZK vs KRaft benchmarking - latency differences?
Doğuşcan Namal
Re: ZK vs KRaft benchmarking - latency differences?
Michael K. Edwards
Re: [DISCUSS] KIP-974 Docker Image for GraalVM based Native Kafka Broker
Justine Olshan
Re: [DISCUSS] KIP-974 Docker Image for GraalVM based Native Kafka Broker
Krishna Agarwal
Re: [DISCUSS] KIP-974 Docker Image for GraalVM based Native Kafka Broker
Justine Olshan
RE: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Diop, Assane
RE: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Diop, Assane
Re: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Greg Harris
RE: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Diop, Assane
Re: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Luke Chen
RE: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Diop, Assane
RE:DISCUSS KIP-984 Add pluggable compression interface to Kafka
Diop, Assane
RE: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Diop, Assane
Re: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Greg Harris
RE: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Diop, Assane
RE: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Diop, Assane
Re: DISCUSS KIP-984 Add pluggable compression interface to Kafka
Greg Harris
[jira] [Created] (KAFKA-16213) KRaft should honor voterId outside of VotedState
Jira
[jira] [Created] (KAFKA-16212) Cache partitions by TopicIdPartition instead of TopicPartition
Gaurav Narula (Jira)
[jira] [Resolved] (KAFKA-16101) KRaft migration rollback documentation is incorrect
Luke Chen (Jira)
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2604
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2605
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2606
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2607
Apache Jenkins Server
[jira] [Resolved] (KAFKA-16186) Implement broker metrics for client telemetry usage
Jun Rao (Jira)
Re: Kafka consumer group crashing and not able to consume once service is up
Matthias J. Sax
RE: Kafka consumer group crashing and not able to consume once service is up
Marigowda, Santhosh Aditya
RE: Kafka consumer group crashing and not able to consume once service is up
Marigowda, Santhosh Aditya
Re: Kafka consumer group crashing and not able to consume once service is up
Philip Nee
Re: Kafka consumer group crashing and not able to consume once service is up
Philip Nee
RE: Kafka consumer group crashing and not able to consume once service is up
Marigowda, Santhosh Aditya
RE: Kafka consumer group crashing and not able to consume once service is up
Marigowda, Santhosh Aditya
[jira] [Created] (KAFKA-16211) Inconsistent static config values in CreateTopicsResult and DescribeConfigsResult
Gantigmaa Selenge (Jira)
[jira] [Resolved] (KAFKA-8606) Provide a method to fetch committed offsets for a collection of TopicPartition
Andrew Schofield (Jira)
[jira] [Resolved] (KAFKA-10184) Flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores
Matthias J. Sax (Jira)
Dynamically update controller configuration
Nelson B.
[jira] [Resolved] (KAFKA-16204) Stray file core/00000000000000000001.snapshot created when running core tests
Mickael Maison (Jira)
Broken build
Josep Prat
Re: Broken build
Luke Chen
Re: Broken build
Josep Prat
Re: Broken build
Greg Harris
Re: Broken build
Justine Olshan
Re: Broken build
Greg Harris
Re: Broken build
Justine Olshan
[jira] [Resolved] (KAFKA-16210) Upgrade jose4j to 0.9.4
Divij Vaidya (Jira)
[jira] [Created] (KAFKA-16210) Upgrade jose4j to 0.9.4
Divij Vaidya (Jira)
Re: [VOTE] KIP-910: Update Source offsets for Source Connectors without producing records
Yash Mayya
Re: [VOTE] KIP-910: Update Source offsets for Source Connectors without producing records
Sagar
Re: [VOTE] KIP-910: Update Source offsets for Source Connectors without producing records
Sagar
[DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Jorge Esteban Quilcate Otoya
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Federico Valeri
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Christo Lolov
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Christo Lolov
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Luke Chen
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
Re: [DISCUSS] KIP-1018: Introduce max remote fetch timeout config
Kamal Chandraprakash
[jira] [Created] (KAFKA-16209) fetchSnapshot might return null if topic is created before v2.8
Luke Chen (Jira)
[jira] [Created] (KAFKA-16208) Design new Consumer timeout policy
Kirk True (Jira)
Re: [DISCUSS] KIP-853: KRaft Voters Change
José Armando García Sancio
[jira] [Created] (KAFKA-16207) Implement KRaft internal listener for KRaftVersionRecord and VotersRecord
Jira
[jira] [Created] (KAFKA-16206) ZkConfigMigrationClient tries to delete topic configs twice
David Arthur (Jira)
[jira] [Created] (KAFKA-16205) Reduce number of metadata requests during hybrid mode
David Arthur (Jira)
Re: [VOTE] KIP-974: Docker Image for GraalVM based Native Kafka Broker
Krishna Agarwal
Re: [VOTE] KIP-974: Docker Image for GraalVM based Native Kafka Broker
Justine Olshan
Re: [VOTE] KIP-974: Docker Image for GraalVM based Native Kafka Broker
Krishna Agarwal
Re: [VOTE] KIP-974: Docker Image for GraalVM based Native Kafka Broker
Ismael Juma
Re: [VOTE] KIP-974: Docker Image for GraalVM based Native Kafka Broker
Krishna Agarwal
[jira] [Created] (KAFKA-16204) Stray file core/00000000000000000001.snapshot created when running core tests
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-16095) Update list group state type filter to include the states for the new consumer group type
David Jacot (Jira)
[jira] [Created] (KAFKA-16203) AutoCommit of empty offsets blocks following requests due to inflight flag
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-16202) Extra dot in error message in producer
Mickael Maison (Jira)
[jira] [Created] (KAFKA-16201) Kafka exception - org.apache.kafka.common.errors.NotLeaderOrFollowerException
Yogesh (Jira)
Re: [VOTE] KIP-995: Allow users to specify initial offsets while creating connectors
Ashwin
Re: [VOTE] KIP-995: Allow users to specify initial offsets while creating connectors
Chris Egerton
Re: [VOTE] KIP-995: Allow users to specify initial offsets while creating connectors
Yash Mayya
Re: [VOTE] KIP-995: Allow users to specify initial offsets while creating connectors
Ashwin
Re: [VOTE] KIP-995: Allow users to specify initial offsets while creating connectors
Chris Egerton
Re: [VOTE] KIP-995: Allow users to specify initial offsets while creating connectors
Ashwin
[jira] [Resolved] (KAFKA-16085) remote copy lag bytes/segments metrics don't update all topic value
Luke Chen (Jira)
[jira] [Created] (KAFKA-16200) Ensure RequestManager handling of expired timeouts are consistent
Kirk True (Jira)
[jira] [Created] (KAFKA-16199) Prune the event queue if events have expired before starting
Kirk True (Jira)
[DISCUSS] KIP-1017: A health check endpoint for Kafka Connect
Chris Egerton
[jira] [Resolved] (KAFKA-16122) TransactionsBounceTest -- server disconnected before response was received
Justine Olshan (Jira)
[jira] [Resolved] (KAFKA-15987) Refactor ReplicaManager code for transaction verification
Justine Olshan (Jira)
[jira] [Resolved] (KAFKA-14505) Implement TnxOffsetCommit API
David Jacot (Jira)
[jira] [Created] (KAFKA-16198) Reconciliation may lose partitions when topic metadata is delayed
Lucas Brutschy (Jira)
[jira] [Created] (KAFKA-16197) Connect Worker poll timeout prints Consumer poll timeout specific warnings.
Sagar Rao (Jira)
[jira] [Created] (KAFKA-16196) Cast transform doesn't handle invalid whole value casts gracefully
Yash Mayya (Jira)
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Jun Rao
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Jun Rao
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Jun Rao
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Jun Rao
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Jun Rao
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Jun Rao
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Jun Rao
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Andrew Schofield
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Jun Rao
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Rowland Smith
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Rowland Smith
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Rowland Smith
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Rowland Smith
Re: [DISCUSS] KIP-939: Support Participation in 2PC
Artem Livshits
Re: Kafka trunk test & build stability
Justine Olshan
Re: Kafka trunk test & build stability
Justine Olshan
RE: Re: Kafka trunk test & build stability
kafka
[jira] [Resolved] (KAFKA-16003) The znode /config/topics is not updated during KRaft migration in "dual-write" mode
Mickael Maison (Jira)
[jira] [Created] (KAFKA-16195) metadata.log.dir failure shouldn't shutdown broker in ZK mode
Gaurav Narula (Jira)
[jira] [Created] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned
David Jacot (Jira)
[jira] [Resolved] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate
Mickael Maison (Jira)
Re: (kafka) branch trunk updated: KAFKA-15585: Implement DescribeTopicPartitions RPC on broker (#14612)
Slathia p
Re: (kafka) branch trunk updated (7e5ef9b509a -> 65596d0a236)
Slathia p
[jira] [Created] (KAFKA-16193) Storing mm2 topics on source side
Mikhail Filatov (Jira)
Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics
Tom Bentley
Re: [VOTE] KIP-877: Mechanism for plugins and connectors to register metrics
Slathia p
Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics
Tom Bentley
Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics
Slathia p
Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics
Luke Chen
Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics
Mickael Maison
Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics
Mickael Maison
Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics
Matthias J. Sax
Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics
Greg Harris
Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics
Mickael Maison
Re: [DISCUSS] KIP-877: Mechanism for plugins and connectors to register metrics
Mickael Maison
[jira] [Created] (KAFKA-16192) Introduce usage of flexible records to coordinators
Justine Olshan (Jira)
[jira] [Created] (KAFKA-16191) Clean up of consumer client internal events
Kirk True (Jira)
Re: [REVIEW REQUEST] ConsumerGroupCommand move to tools
Николай Ижиков
Re: [REVIEW REQUEST] ConsumerGroupCommand move to tools
Slathia p
[jira] [Resolved] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-16135) kafka.api.PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky
Lianet Magrans (Jira)
[jira] [Created] (KAFKA-16190) Member should send full heartbeat when rejoining
Lianet Magrans (Jira)
[jira] [Resolved] (KAFKA-16107) Ensure consumer does not start fetching from added partitions until onPartitionsAssigned completes
David Jacot (Jira)
[jira] [Created] (KAFKA-16189) Extend admin to support ConsumerGroupDescribe API
David Jacot (Jira)
[jira] [Created] (KAFKA-16188) Delete deprecated kafka.common.MessageReader
Mickael Maison (Jira)
[jira] [Resolved] (KAFKA-15813) Improve implementation of client instance cache
Jun Rao (Jira)
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.6 #140
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.6 #141
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.6 #142
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.6 #143
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.6 #144
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.6 #145
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.6 #146
Apache Jenkins Server
[jira] [Resolved] (KAFKA-15683) Delete subscription from metadata when all configs are deleted
Apoorv Mittal (Jira)
[jira] [Created] (KAFKA-16187) Flaky test: testTopicPatternArg - org.apache.kafka.tools.GetOffsetShellTest
Apoorv Mittal (Jira)
Re: [PR] MINOR: Sort powered by page output alphabetically [kafka-site]
via GitHub
Re: [PR] MINOR: Sort powered by page output alphabetically [kafka-site]
via GitHub
Re: [PR] MINOR: Sort powered by page output alphabetically [kafka-site]
via GitHub
Re: [PR] MINOR: Sort powered by page output alphabetically [kafka-site]
via GitHub
Re: [PR] MINOR: Sort powered by page output alphabetically [kafka-site]
via GitHub
Re: [PR] MINOR: Sort powered by page output alphabetically [kafka-site]
via GitHub
Re: [PR] MINOR: Sort powered by page output alphabetically [kafka-site]
via GitHub
Re: [PR] MINOR: Sort powered by page output alphabetically [kafka-site]
via GitHub
Re: [PR] MINOR: Sort powered by page output alphabetically [kafka-site]
via GitHub
Re: [PR] MINOR: Sort powered by page output alphabetically [kafka-site]
via GitHub
[jira] [Created] (KAFKA-16186) Implement broker metrics for client telemetry usage
Apoorv Mittal (Jira)
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2596
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2597
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2598
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2599
Apache Jenkins Server
Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #2600
Apache Jenkins Server
Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #2601
Apache Jenkins Server
Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2602
Apache Jenkins Server
Re: Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2602
Slathia p
[jira] [Resolved] (KAFKA-16144) Controller leader checkQuorum timer should skip only 1 controller case
Luke Chen (Jira)
[jira] [Resolved] (KAFKA-16166) Generify RetryWithToleranceOperator and ErrorReporter
Greg Harris (Jira)
Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes
José Armando García Sancio
Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes
José Armando García Sancio
Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes
José Armando García Sancio
Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes
Luke Chen
Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes
José Armando García Sancio
Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes
Slathia p
Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes
Luke Chen
Re: [DISCUSS] KIP-853: KRaft Controller Membership Changes
José Armando García Sancio
Earlier messages
Later messages