kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Stein <joe.st...@stealth.ly>
Subject New Java producer question
Date Mon, 10 Nov 2014 16:11:22 GMT
In the new Java producer I see that you can set RETRY_BACKOFF_MS_CONFIG
https://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java#L112
which is used
https://github.com/apache/kafka/blob/0.8.2/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java#L217-L226
but
I don't see (maybe just missing it??? I haven't spent a lot of quality time
with the code yet) how to set the number of retry this happens before
failure as we have in the existing producer
https://github.com/apache/kafka/blob/0.8.2/core/src/main/scala/kafka/producer/ProducerConfig.scala#L98
or is this done another way or no longer required or used???

/*******************************************
 Joe Stein
 Founder, Principal Consultant
 Big Data Open Source Security LLC
 http://www.stealth.ly
 Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
********************************************/

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message