kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-4944; Fix an "unread field" findbugs warning in streams examples
Date Wed, 29 Mar 2017 15:33:28 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 7adf1e414 -> aea5989d9


KAFKA-4944; Fix an "unread field" findbugs warning in streams examples

Author: Colin P. Mccabe <cmccabe@confluent.io>

Reviewers: Michael G. Noll <michael@confluent.io>, Ismael Juma <ismael@juma.me.uk>

Closes #2727 from cmccabe/KAFKA-4944


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/aea5989d
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/aea5989d
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/aea5989d

Branch: refs/heads/trunk
Commit: aea5989d988cd1b46c95409989a7c12c7cf52b5f
Parents: 7adf1e4
Author: Colin P. Mccabe <cmccabe@confluent.io>
Authored: Wed Mar 29 16:26:29 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Wed Mar 29 16:33:12 2017 +0100

----------------------------------------------------------------------
 .../kafka/streams/examples/pageview/JsonPOJOSerializer.java      | 4 ----
 1 file changed, 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/aea5989d/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonPOJOSerializer.java
----------------------------------------------------------------------
diff --git a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonPOJOSerializer.java
b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonPOJOSerializer.java
index fa82c24..6a5abea 100644
--- a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonPOJOSerializer.java
+++ b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonPOJOSerializer.java
@@ -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


Mime
View raw message