root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Minor cleanup

This commit is contained in:
Ewen Cheslack-Postava 2015-07-31 20:09:06 -07:00
parent 122423eef7
commit be5c387a0e
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
copycat-json/src/main/java/org/apache/kafka/copycat/json/JsonSerializer.java
View File

@ -32,7 +32,7 @@ public class JsonSerializer implements Serializer<JsonNode> {
private static final String SCHEMAS_ENABLE_CONFIG = "schemas.enable"; private static final String SCHEMAS_ENABLE_CONFIG = "schemas.enable";
private static final boolean SCHEMAS_ENABLE_DEFAULT = true; private static final boolean SCHEMAS_ENABLE_DEFAULT = true;
private ObjectMapper objectMapper = new ObjectMapper(); private final ObjectMapper objectMapper = new ObjectMapper();
private boolean enableSchemas = SCHEMAS_ENABLE_DEFAULT; private boolean enableSchemas = SCHEMAS_ENABLE_DEFAULT;
/** /**

3
copycat-runtime/src/main/java/org/apache/kafka/copycat/runtime/Worker.java
View File

@ -77,8 +77,7 @@ public class Worker {
Deserializer offsetKeyDeserializer, Deserializer offsetValueDeserializer) { Deserializer offsetKeyDeserializer, Deserializer offsetValueDeserializer) {
this.time = time; this.time = time;
this.config = config; this.config = config;
this.converter = Reflection.instantiate(config.getClass(WorkerConfig.CONVERTER_CLASS_CONFIG).getName(), this.converter = Reflection.instantiate(config.getClass(WorkerConfig.CONVERTER_CLASS_CONFIG).getName(), Converter.class);
Converter.class);
this.offsetBackingStore = offsetBackingStore; this.offsetBackingStore = offsetBackingStore;
if (offsetKeySerializer != null) { if (offsetKeySerializer != null) {