ksql 连接报错

[2020-12-18 08:55:36,854] ERROR Failed to start KSQL (io.confluent.ksql.rest.server.KsqlServerMain:68)
io.confluent.ksql.util.KsqlServerException: Could not get Kafka authorized operations!
at io.confluent.ksql.services.KafkaClusterUtil.isAuthorizedOperationsSupported(KafkaClusterUtil.java:57)
at io.confluent.ksql.security.KsqlAuthorizationValidatorFactory.create(KsqlAuthorizationValidatorFactory.java:52)
at io.confluent.ksql.rest.server.KsqlRestApplication.buildApplication(KsqlRestApplication.java:691)
at io.confluent.ksql.rest.server.KsqlRestApplication.buildApplication(KsqlRestApplication.java:606)
at io.confluent.ksql.rest.server.KsqlServerMain.createExecutable(KsqlServerMain.java:161)
at io.confluent.ksql.rest.server.KsqlServerMain.main(KsqlServerMain.java:61)
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default includeClusterAuthorizedOperations at version 7
at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at org.apache.kafka.common.internals.KafkaFutureImpl.accessSingleWaiter.await(KafkaFutureImpl.java:89)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
at io.confluent.ksql.services.KafkaClusterUtil.isAuthorizedOperationsSupported(KafkaClusterUtil.java:53)
... 5 more
Caused by: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default includeClusterAuthorizedOperations at version 7

换版本：
confluentinc/cp-ksqldb-server:6.0.1

使用
admin

docker run -d \
-p 0.0.0.0:8088:8088   \
-e KSQL_BOOTSTRAP_SERVERS=192.1.1.1:9092   \
-e KSQL_LISTENERS=http://0.0.0.0:8088/   \
-e KSQL_KSQL_SERVICE_ID=ksql_service_2_   \
-e KSQL_SECURITY_PROTOCOL=SASL_PLAINTEXT   \
-e KSQL_SASL_MECHANISM=PLAIN   \
-e KSQL_SASL_JAAS_CONFIG="org.apache.kafka.common.security.plain.PlainLoginModule required username=\"xx\" password=\"xx\";"   \
confluentinc/cp-ksqldb-server:6.0.1