This is an automated email from the ASF dual-hosted git repository. jwills pushed a commit to branch jwills_great_version_upgrade in repository https://gitbox.apache.org/repos/asf/crunch.git
commit 65afa91dbaff02fb3900c4a065820a4411bd8ef7 Author: Josh Wills <[email protected]> AuthorDate: Thu Nov 14 13:50:59 2019 -0800 and more more fixes --- crunch-kafka/src/test/java/org/apache/crunch/kafka/KafkaUtilsIT.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/crunch-kafka/src/test/java/org/apache/crunch/kafka/KafkaUtilsIT.java b/crunch-kafka/src/test/java/org/apache/crunch/kafka/KafkaUtilsIT.java index dc4ea82..707f1b3 100644 --- a/crunch-kafka/src/test/java/org/apache/crunch/kafka/KafkaUtilsIT.java +++ b/crunch-kafka/src/test/java/org/apache/crunch/kafka/KafkaUtilsIT.java @@ -25,7 +25,7 @@ import org.apache.hadoop.conf.Configuration; import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.common.TopicPartition; import org.apache.kafka.common.network.ListenerName; -import org.apache.kafka.common.protocol.SecurityProtocol; +import org.apache.kafka.common.security.auth.SecurityProtocol; import org.junit.AfterClass; import org.junit.Before; import org.junit.BeforeClass;
