From 2e1feb3fc49edf35dfc6eb26b6bf40fe1f7283da Mon Sep 17 00:00:00 2001
From: Gary Russell <grussell@vmware.com>
Date: Thu, 29 Sep 2022 14:39:07 -0400
Subject: [PATCH] Don't Use kafka.common.KafkaException in Broker

Removed in 3.3.

Use `org.apache.kafka.common.KafkaException` instead.
---
 .../org/springframework/kafka/test/EmbeddedKafkaBroker.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java b/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java
index 77be6425..4ed1da4c 100644
--- a/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java
+++ b/spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java
@@ -50,6 +50,7 @@ import org.apache.kafka.clients.admin.CreateTopicsResult;
 import org.apache.kafka.clients.admin.NewTopic;
 import org.apache.kafka.clients.consumer.Consumer;
 import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
+import org.apache.kafka.common.KafkaException;
 import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.common.security.auth.SecurityProtocol;
 import org.apache.kafka.common.utils.AppInfoParser;
@@ -71,7 +72,6 @@ import org.springframework.retry.support.RetryTemplate;
 import org.springframework.util.Assert;
 
 import kafka.cluster.EndPoint;
-import kafka.common.KafkaException;
 import kafka.server.KafkaBroker;
 import kafka.server.KafkaConfig;
 import kafka.server.KafkaServer;