Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
Due to change of class location of SecurityProtocol, KafkaClusterConfig.java needs to be modified so that it compiles against the Kafka 1.0.0 release:
-import org.apache.kafka.common.protocol.SecurityProtocol; +import org.apache.kafka.common.security.auth.SecurityProtocol;
A compatibility layer may be needed if we support multiple Kafka releases simultaneously.