Drop use of OutputCapture in SampleKafkaApplicationTests

Closes gh-15432
This commit is contained in:
Andy Wilkinson
2018-12-10 10:11:50 +00:00
parent 83de570f33
commit 9a97e1b0f7
2 changed files with 19 additions and 10 deletions

View File

@@ -16,15 +16,25 @@
package sample.kafka;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;
@Component
class Consumer {
private final List<SampleMessage> messages = new CopyOnWriteArrayList<>();
@KafkaListener(topics = "testTopic")
public void processMessage(SampleMessage message) {
this.messages.add(message);
System.out.println("Received sample message [" + message + "]");
}
List<SampleMessage> getMessages() {
return this.messages;
}
}