Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # dev >> Review Request 18343: KAFKA-1250: Add logging to new Kafka producer.


Copy link to this message
-
Re: Review Request 18343: KAFKA-1250: Add logging to new Kafka producer.

This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/18343/#review35431
A few remaining things that we need to take care of -

1. Adding proper logging for retries
2. Converting remaining printStackTrace() statements to use the logger
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
<https://reviews.apache.org/r/18343/#comment65931>

    could we also have config.logOveridden() ?

clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
<https://reviews.apache.org/r/18343/#comment65934>

    My understanding is that any per message log message be at trace and rest be at debug(). Very few remaining user facing messages should be at info().
    
    Given that, should this also be at trace()?

clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
<https://reviews.apache.org/r/18343/#comment65935>

    Since this is not a per message but instead is a per producer message, can this be at debug()?
    
    Can we also have corresponding log messages on producer startup?

clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
<https://reviews.apache.org/r/18343/#comment65936>

    same here

clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
<https://reviews.apache.org/r/18343/#comment65940>

    Since this is also not expected per message, should this be at debug()?

clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordBatch.java
<https://reviews.apache.org/r/18343/#comment65941>

    Let's also specify the topic partition here.

clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordBatch.java
<https://reviews.apache.org/r/18343/#comment65942>

    Same here. Can we also specify the topic partition here?

clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
<https://reviews.apache.org/r/18343/#comment65943>

    can this be at debug?

clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
<https://reviews.apache.org/r/18343/#comment65944>

    same here
- Neha Narkhede
On Feb. 21, 2014, 4:26 a.m., Jay Kreps wrote: