get rid of var
@@ -60,8 +60,7 @@ public class ProtobufUtil {
for (Entry<String, String> entry : messageFormatByTopic.entrySet()) {
String topic = entry.getKey();
String format = entry.getValue();
- allTopics = "*".equals(topic);
- if(allTopics) {
+ if("*".equals(topic)) {
messageFormatForAll = format;
LOG.info("Assuming the format: {} for all Kafka topics", format);
break;
