Skip to content

Commit cc3d421

Browse files
bgKgaryrussell
authored andcommitted
GH-780: kafka-client jar 2.0.x with KafkaEmbedded
Resolves #780
1 parent f9f7d9c commit cc3d421

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-kafka-test/src/main/java/org/springframework/kafka/test/rule/KafkaEmbedded.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ public class KafkaEmbedded extends ExternalResource implements KafkaRule, Initia
9999

100100
static {
101101
clientVersion = AppInfoParser.getVersion();
102-
if (clientVersion.startsWith("1.1.")) {
102+
if (clientVersion.startsWith("1.1.") || clientVersion.startsWith("2.0.")) {
103103
try {
104104
testUtilsCreateBrokerConfigMethod = TestUtils.class.getDeclaredMethod("createBrokerConfig",
105105
int.class, String.class, boolean.class, boolean.class, int.class,

0 commit comments

Comments
 (0)