Re: [DISCUSS] KIP-388 Add observer interface to record request and response

Hey Lincong, Thanks for the explanation. Here are my concern with the current proposal: 1) The current APIs of RequestInfo/ResponseInfo only provide byte and count number of ProduceRequest/FetchRespnse. With these limited AIPs, developers will likely have to create new KIP and make change in Apac

[DISCUSS] KIP-390: Add producer option to adjust compression level

Hello dev, I hope to initiate the discussion of KIP-390: Add producer option to adjust compression level . All feedbacks will be highly appreciated. Best, Dongjin -- *Dongjin Lee* *A h

Re: [VOTE] 2.1.0 RC1

+1 (non-binding) - Ran testAll/releaseTarGzAll on 2.1.0 successfully without any failures. - Ran through quickstart of core/streams on builds generated from tag - Ran few internal apps targeting to topics on 3 node cluster. Thanks, Satish. On Sun, Nov 18, 2018 at 4:58 AM Jakub Scholz wrote: > >

Re: [DISCUSS] KIP-388 Add observer interface to record request and response

Hi Dong and Patrick, Thank you very much for feedbacks! Firstly I want to clarify that the implementations of RequestInfo and ResponseInfo are *not* provided by user. Instead they will be provided as part of this KIP. In other words, "RequestAdapter" and "ResponseAdapter" are implementations of "R

[jira] [Created] (KAFKA-7653) Streams-Scala: Add type level differentiation for Key and Value serdes.

Mark Tranter created KAFKA-7653: --- Summary: Streams-Scala: Add type level differentiation for Key and Value serdes. Key: KAFKA-7653 URL: https://issues.apache.org/jira/browse/KAFKA-7653 Project: Kafka