Fix typo in logs

This commit is contained in:
Dave Syer
2018-05-08 17:57:47 +01:00
parent 7f04af6e73
commit 4d2a15cee9

View File

@@ -142,7 +142,7 @@ public class KafkaApplication {
@Override @Override
public void stop() { public void stop() {
if (this.running.compareAndSet(true, false)) { if (this.running.compareAndSet(true, false)) {
log.info("Stoping Kafka"); log.info("Stopping Kafka");
try { try {
if (kafkaServer.brokerState() if (kafkaServer.brokerState()
.currentState() != (NotRunning.state())) { .currentState() != (NotRunning.state())) {