你好,在开启kerberos的kafka集群,通过kafka客户端模式如何启动kafka connect的standalone模式?kerberos认证信息要写在哪个配置文件中?是connect-standalone.properties这个文件吗?有样例吗?
现在集群是TDH的,我这边是利用的客户端模式,执行的,是要去看kafka集群的吗?还是看客户端的?
以下是客户端执行报错:
[2021-04-13 17:59:11,746] WARN Bootstrap broker mytest403:9092 disconnected (org.apache.kafka.clients.NetworkClient:694)
[2021-04-13 17:59:11,782] ERROR Failed to flush WorkerSourceTask{id=oracle-kafka-connector-0}, timed out while waiting for producer to flush outstanding 1 messages (org.apache.kafka.connect.runtime.WorkerSourceTask:304)
[2021-04-13 17:59:11,783] ERROR Failed to commit offsets for WorkerSourceTask{id=oracle-kafka-connector-0} (org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:112)