Hi TaiJuWu, Thanks for the KIP!
Can you explain in the KIP about the behavior when the number of acks is different for individual records? I think the current description using the word "straightforward" does little to explain that, and may actually be hiding some complexity. For example, the send() javadoc contains this: "Callbacks for records being sent to the same partition are guaranteed to execute in order." Is this still true when acks vary for records within the same partition? If so, are low-acks records subject to head-of-line-blocking from high-acks records? It seems to me that this feature is useful when acks is specified per-topic, but introduces a lot of edge cases that are underspecified. Thanks, Greg On Tue, Nov 5, 2024 at 4:52 PM TaiJu Wu <tjwu1...@gmail.com> wrote: > Hi Chia-Ping, > > Thanks for your feedback. > I have updated KIP based on your suggestions. > > Best, > Stanley > > Chia-Ping Tsai <chia7...@apache.org> 於 2024年11月5日 週二 下午4:41寫道： > > > hi TaiJuWu, > > > > Q0: Could you please add getter (Short acks()) to "public interface" > > section? > > > > Q1: Could you please add RPC json reference to prove "been available at > > the RPC-level," > > > > Q2: Could you please add link to producer docs to prove "share a single > > producer instance across multiple threads" > > > > Thanks, > > Chia-Ping > > > > On 2024/11/05 01:28:36 吳岱儒 wrote: > > > Hi all, > > > > > > I open a KIP-1107: Adding record-level acks for producers > > > < > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1107%3A++Adding+record-level+acks+for+producers > > > > > > to > > > reduce the limitation associated with reusing KafkaProducer. > > > > > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1107%3A++Adding+record-level+acks+for+producers > > > > > > Feedbacks and suggestions are welcome. > > > > > > Thanks, > > > TaiJuWu > > > > > >
