Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #281

2025-04-27 Thread Apache Jenkins Server
See

Re: Request Confluence permission to submit KIP

2025-04-27 Thread Matthias J. Sax
You should be all set. On 4/26/25 3:38 AM, 鍾明諺 wrote: Dear Kafka Team, I would like to request permission for the Kafka Confluence in order to submit a KIP. My Confluence username is "*mingyen066"* Thank you very much for your support! Best regards, Ming

[jira] [Created] (KAFKA-19208) KStream-GlobalKTable join should not drop left-null-key record

2025-04-27 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-19208: --- Summary: KStream-GlobalKTable join should not drop left-null-key record Key: KAFKA-19208 URL: https://issues.apache.org/jira/browse/KAFKA-19208 Project: Kafka

[jira] [Resolved] (KAFKA-19183) Replace Pool with ConcurrentHashMap

2025-04-27 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-19183. Fix Version/s: 4.1.0 Resolution: Fixed > Replace Pool with ConcurrentHashMap >

Re: a question of ISR and ack all

2025-04-27 Thread XiJun Ye
Thank you a lot! > 2025年4月27日 17:48,Haruki Okada 写道: > > With acks=all, it is guaranteed that a message is replicated to all ISRs on > successful produce response. > > lag.time.max is used to determine which replica is in sync, not to > determine a message is replicated. > > On Sun, Apr 27, 20

Re: a question of ISR and ack all

2025-04-27 Thread Haruki Okada
With acks=all, it is guaranteed that a message is replicated to all ISRs on successful produce response. lag.time.max is used to determine which replica is in sync, not to determine a message is replicated. On Sun, Apr 27, 2025, 18:37 XiJun Ye wrote: > I have a question about data consistency.

a question of ISR and ack all

2025-04-27 Thread XiJun Ye
I have a question about data consistency. Kafka ISR only determines the time of lag, not the number of messages. Does ack=all require the replicas in the ISR to completely catch up with the number of messages or to meet the time requirement? For example, if there are 3 replicas in the ISR, min.