[jira] [Created] (KAFKA-12854) Add a config to allow skipping metadata cache update when topic partition is unassigned

Lincong Li created KAFKA-12854: -- Summary: Add a config to allow skipping metadata cache update when topic partition is unassigned Key: KAFKA-12854 URL: https://issues.apache.org/jira/browse/KAFKA-12854

[jira] [Created] (KAFKA-10823) AdminOperationException has no error code

Lincong Li created KAFKA-10823: -- Summary: AdminOperationException has no error code Key: KAFKA-10823 URL: https://issues.apache.org/jira/browse/KAFKA-10823 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-10606) Auto create non-existent topics when fetching metadata for all topics

Lincong Li created KAFKA-10606: -- Summary: Auto create non-existent topics when fetching metadata for all topics Key: KAFKA-10606 URL: https://issues.apache.org/jira/browse/KAFKA-10606 Project: Kafka

Re: Kafka Lag Monitor

Burrow? https://github.com/linkedin/Burrow On Sun, Jan 12, 2020 at 9:26 AM Suman Pattnaik wrote: > Is there a good tool to watch Kafka lags and is free ? > > Thanks, > Suman > >

Re: Broker Interceptors

s for Kafka Audit" section at the end of KIP-388 sheds some lights on the client-side auditor/interceptor/observer (sorry about the potential confusion caused by these words being used interchangeably). Best regards, Lincong Li On Wed, Dec 4, 2019 at 8:15 AM Thomas Aley wrote: > Thanks f

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

its it can bring to the community. Thanks, Lincong Li On Sun, Nov 18, 2018 at 9:35 PM Dong Lin wrote: > 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 &

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

information are exposed and still provides its implementation. For Dong, Your proposed approach is not obvious to me and I will need further study and reading through the source to understand. However, with my clarification on the fact that internal classes are not exposed, do you think my proposed approach ha

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

initialization might be wasteful. For example, methods such as " public Map getFetchFromTopicPartitionSizeInBytes()" takes non-constant time. Best regards, Lincong Li On Tue, Nov 13, 2018 at 5:56 PM xiongqi wu wrote: > Lincong, > > Thanks for the KIP. > I have a questi

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

pair" by providing a sample code block which shows how these interfaces are used in the KafkaApis class. Let me know if you have any question, concern, or comments. Thank you very much! Best regards, Lincong Li On Fri, Nov 9, 2018 at 10:34 AM Mayuresh Gharat wrote: > Hi Lincong, > >

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

Hi everyone. Here <https://cwiki.apache.org/confluence/display/KAFKA/KIP-388%3A+Add+observer+interface+to+record+request+and+response> is my KIP. Any feedback is appreciated. Thanks, Lincong Li

[jira] [Created] (KAFKA-7596) Add observer interface to record request and response

Lincong Li created KAFKA-7596: - Summary: Add observer interface to record request and response Key: KAFKA-7596 URL: https://issues.apache.org/jira/browse/KAFKA-7596 Project: Kafka Issue Type

[jira] [Created] (KAFKA-7573) Add an interface that allows broker to intercept every request/response pair

Lincong Li created KAFKA-7573: - Summary: Add an interface that allows broker to intercept every request/response pair Key: KAFKA-7573 URL: https://issues.apache.org/jira/browse/KAFKA-7573 Project: Kafka

[jira] [Created] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

Lincong Li created KAFKA-7196: - Summary: Remove heartbeat delayed operation for those removed consumers at the end of each rebalance Key: KAFKA-7196 URL: https://issues.apache.org/jira/browse/KAFKA-7196