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

Don't Use kafka.common.KafkaException in Broker

Browse Source 
Removed in 3.3.

Use `org.apache.kafka.common.KafkaException` instead.
This commit is contained in:
Gary Russell
2022-09-29 14:39:07 -04:00
parent 34c48f5ec5
commit 2e1feb3fc4
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-kafka-test/src/main/java/org/springframework/kafka/test/EmbeddedKafkaBroker.java
View File

@@ -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;