Github user tgravescs commented on a diff in the pull request:
https://github.com/apache/storm/pull/572#discussion_r33256167
--- Diff: external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java ---
@@ -53,10 +55,13 @@
public static final String TOPIC = "topic";
public static final String KAFKA_BROKER_PROPERTIES =
"kafka.broker.properties";
- private Producer<K, V> producer;
+ private KafkaProducer<K, V> producer;
private OutputCollector collector;
private TupleToKafkaMapper<K,V> mapper;
private KafkaTopicSelector topicSelector;
+ /* With default setting for fireAndForget and async, the callback is
called when sending succeed */
+ private boolean fireAndForget = false; /* by setting as true, each
send immediately gets acked by collector */
+ private boolean async = true; /* by setting this as false, synchronous
sending is used. Also refer to "acks" config in new Producer API */
--- End diff --
put the comments above so we don't exceed 80 characters.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
