我正在为postgres的debezium连接器运行kubernetes吊舱。
https://debezium.io/documentation/reference/connectors/postgresql.html
我在pod日志中发现以下错误

[2020-11-19 22:20:27,466] WARN Error executing interceptor onAcknowledgement callback (org.apache.kafka.clients.producer.internals.ProducerInterceptors)
java.lang.IllegalStateException: Publishing thread must be running to enable recording of metrics for client_id=connector-producer-postgres-source-reportingdb-0 client_type=PRODUCER session= cluster=d3QOqg9_R9aKj2Re3Huc3w
        at io.confluent.monitoring.clients.interceptor.MonitoringInterceptor.recordMessageMetric(MonitoringInterceptor.java:208)
        at io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor.onAcknowledgement(MonitoringProducerInterceptor.java:93)
        at org.apache.kafka.clients.producer.internals.ProducerInterceptors.onAcknowledgement(ProducerInterceptors.java:88)
        at org.apache.kafka.clients.producer.KafkaProducer$InterceptorCallback.onCompletion(KafkaProducer.java:1316)
        at org.apache.kafka.clients.producer.internals.ProducerBatch.completeFutureAndFireCallbacks(ProducerBatch.java:227)
        at org.apache.kafka.clients.producer.internals.ProducerBatch.done(ProducerBatch.java:196)
        at org.apache.kafka.clients.producer.internals.Sender.completeBatch(Sender.java:696)
        at org.apache.kafka.clients.producer.internals.Sender.completeBatch(Sender.java:677)
        at org.apache.kafka.clients.producer.internals.Sender.handleProduceResponse(Sender.java:585)
        at org.apache.kafka.clients.producer.internals.Sender.access$100(Sender.java:73)
        at org.apache.kafka.clients.producer.internals.Sender$1.onComplete(Sender.java:789)
        at org.apache.kafka.clients.ClientResponse.onComplete(ClientResponse.java:109)
        at org.apache.kafka.clients.NetworkClient.completeResponses(NetworkClient.java:561)
        at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:553)
        at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:331)
        at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:238)
        at java.lang.Thread.run(Thread.java:748)

有人知道原因和解决方法吗？