Fix test

garyrussell · garyrussell · commit f4a0a239c262 · 2019-01-09T13:53:36.000-05:00
https://build.spring.io/browse/SK-MAS-573/ Use a unique group for the `bytesKey()` listener.
diff --git a/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java b/spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java
@@ -1604,7 +1604,8 @@ public void ackWithAutoContainerListener(String payload, Acknowledgment ack) {
 			// empty
 		}
 
-		@KafkaListener(topics = "annotated36", containerFactory = "bytesStringListenerContainerFactory")
+		@KafkaListener(id = "bytesKey", topics = "annotated36",
+				containerFactory = "bytesStringListenerContainerFactory")
 		public void bytesKey(String in, @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key) {
 			this.convertedKey = key;
 			this.keyLatch.countDown();

Original file line number	Diff line number	Diff line change
`@@ -1604,7 +1604,8 @@ public void ackWithAutoContainerListener(String payload, Acknowledgment ack) {`
`1604`	`1604`	`// empty`
`1605`	`1605`	`}`
`1606`	`1606`
`1607`		`- @KafkaListener(topics = "annotated36", containerFactory = "bytesStringListenerContainerFactory")`
	`1607`	`+ @KafkaListener(id = "bytesKey", topics = "annotated36",`
	`1608`	`+ containerFactory = "bytesStringListenerContainerFactory")`
`1608`	`1609`	`public void bytesKey(String in, @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key) {`
`1609`	`1610`	`this.convertedKey = key;`
`1610`	`1611`	`this.keyLatch.countDown();`