Fix an "unread field" findbugs warning in streams examples
Author: Colin P. Mccabe
Reviewers: Michael G. Noll Ismael Juma
Closes from cmccabe/KAFKA-4944
@@ -26,19 +26,15 @@ import java.util.Map;
public class JsonPOJOSerializer<T> implements Serializer<T> {
private final ObjectMapper objectMapper = new ObjectMapper();
- private Class<T> tClass;
-
/**
* Default constructor needed by Kafka
*/
public JsonPOJOSerializer() {
-
}
@SuppressWarnings("unchecked")
@Override
public void configure(Map<String, ?> props, boolean isKey) {
- tClass = (Class<T>) props.get("JsonPOJOClass");
}
@Override
