脾气比较躁

0 声望

这家伙太懒,什么都没留下

个人动态
  • 脾气比较躁 回复 半兽人Kafka Connect配置 中 :

    你好,在开启kerberos的kafka集群,通过kafka客户端模式如何启动kafka connect的standalone模式?kerberos认证信息要写在哪个配置文件中?是connect-standalone.properties这个文件吗?有样例吗?

    3年前
  • 半兽人 回复 脾气比较躁Kafka Connect配置 中 :

    去看看kafka集群日志的报错。

    3年前
  • 脾气比较躁 回复 半兽人Kafka Connect配置 中 :

    现在集群是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)
    
    3年前
  • 半兽人 回复 脾气比较躁Kafka Connect配置 中 :

    你要到kafka日志中找具体的报错原因。

    3年前