Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Further Improve Kafka Test Run Time

Browse Source 
Configurable `timeoutBuffer`.
This commit is contained in:
Gary Russell
2020-10-16 15:43:13 -04:00
committed by Artem Bilan
parent a136b5b49a
commit 75d14d32e7
2 changed files with 25 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
spring-integration-kafka/src/test/java/org/springframework/integration/kafka/config/xml/KafkaOutboundAdapterParserTests.java
View File

@@ -122,6 +122,7 @@ class KafkaOutboundAdapterParserTests {
handler.setSync(true);
handler.setSendTimeout(10);
handler.setTimeoutBuffer(200);
handler.setTopicExpression(new LiteralExpression("foo"));
Executors.newSingleThreadExecutor()