Fixed the broken tests

This commit is contained in:
Marcin Grzejszczak
2018-04-05 16:08:27 +02:00
parent 3108ec23f7
commit 13ff16e2a5

View File

@@ -90,7 +90,7 @@ public class TraceMessagingAutoConfigurationTests {
return new MySleuthKafkaAspect(kafkaTracing, tracer);
}
@KafkaListener(topics = "backend")
@KafkaListener(topics = "backend", groupId = "foo")
public void onMessage(ConsumerRecord<?, ?> message) {
System.err.println(message);
}