Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2476#discussion_r158124853
--- Diff:
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/TridentKafkaState.java
---
@@ -73,7 +71,7 @@ public void commit(Long txid) {
public void prepare(Properties options) {
Objects.requireNonNull(mapper, "mapper can not be null");
Objects.requireNonNull(topicSelector, "topicSelector can not be
null");
- producer = new KafkaProducer(options);
+ producer = new KafkaProducer<K, V>(options);
--- End diff --
Nit: I think `new KafkaProducer<>(options)` will work here
---
