wenze159632

icon company Shanghai Jiaotong University icon location Shanghai icon location Student of Shanghai Jiaotong University

Results 1 issues of wenze159632

There is a problem with the logic of creating a producer function in driver-kop

The original code and fix are as follows. ``` public CompletableFuture createProducer(String topic) { if (config.producerType.equals(ClientType.KAFKA)) { final BenchmarkProducer producer = new KafkaBenchmarkProducer(new KafkaProducer(producerProperties), topic); producers.add(producer); return CompletableFuture.completedFuture(producer); } else...