fix serdes in ValidationsAggregatorService
@@ -123,8 +123,9 @@ public class ValidationsAggregatorService implements Service {
}
public static void main(String[] args) throws Exception {
+ final String bootstrapServers = parseArgsAndConfigure(args);
ValidationsAggregatorService service = new ValidationsAggregatorService();
- service.start(parseArgsAndConfigure(args), "/tmp/kafka-streams");
+ service.start(bootstrapServers, "/tmp/kafka-streams");
addShutdownHookAndBlock(service);
}
}
