----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/19831/#review39328 -----------------------------------------------------------
Ship it! Minor comments below that you can fix on checkin clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java <https://reviews.apache.org/r/19831/#comment71672> We also fetch metadata when there are topic changes or leader changes. Could we update the docs to clarify that? clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java <https://reviews.apache.org/r/19831/#comment72030> Add retry.backoff.ms inside the <code> block clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java <https://reviews.apache.org/r/19831/#comment72031> this should be compression.type - Neha Narkhede On March 30, 2014, 6:48 p.m., Jay Kreps wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/19831/ > ----------------------------------------------------------- > > (Updated March 30, 2014, 6:48 p.m.) > > > Review request for kafka. > > > Bugs: KAFKA-1337 > https://issues.apache.org/jira/browse/KAFKA-1337 > > > Repository: kafka > > > Description > ------- > > KAFKA-1337 Rationalize the producer configs. > > > Diffs > ----- > > clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java > 8c1c5751a9186e6bc3196d152e4c3e948cc34b39 > clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java > 259c14bd072a18c8e6a6b851db9fb8131da7426c > > clients/src/main/java/org/apache/kafka/clients/tools/ProducerPerformance.java > 3b3fb2c36fc45cc24da5008141310019befb05a9 > clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java > 84a327e8c1f06840492abc38e5cb0446cfbc7541 > clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java > 67b349dc8d840b0b7bfb4bedde819e092dc48d21 > clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java > 3950eb13d37e41276db9b4d2db24c2b1f4118fc2 > clients/src/main/java/org/apache/kafka/common/metrics/MetricsReporter.java > 2c395b1f8f3434625959f70d2f4fec40857270e8 > clients/src/test/java/org/apache/kafka/common/config/ConfigDefTest.java > 29543dfa34d5f26397d9327d4e8d0c87b28b1fa9 > core/src/test/scala/integration/kafka/api/ProducerCompressionTest.scala > 1d73aca658a9ea31e76c3e12575703823ed0428f > core/src/test/scala/integration/kafka/api/ProducerFailureHandlingTest.scala > 525a06076bda51eaf001fb0a47091094c06c35f7 > core/src/test/scala/integration/kafka/api/ProducerSendTest.scala > 3c37330a366e84eb3bf0a96ed45de6e3f01b0a71 > > Diff: https://reviews.apache.org/r/19831/diff/ > > > Testing > ------- > > > Thanks, > > Jay Kreps > >
