我有一个工作的s3接收器连接器,直到源连接器发送一个空值;s3连接器崩溃。当我从MS SQL数据库中删除记录时出现问题。源连接器将删除信息发送到s3连接器,s3连接器崩溃。我删除并重新创建了具有不同名称的s3连接器,没有任何更改。) [task-thread-minio-connector1-0] a
我想要存储数据从卡夫卡到桶s3使用卡夫卡连接。我已经有了一个卡夫卡的主题运行,我有一个桶s3创建。] INFO (Re-)joining group connect-s3-sink (org.apache.kafka.clients.consumer.internals.AbstractCoordinatorat org.apache.kafka.connect.runtime.WorkerSinkTask.closePartitions(WorkerSinkTask.java:421)
org.apache.kafka.clients.producer.BufferExhaustedException: Failed to allocate memory within the configured这表示当producer无法在配置的最大阻塞时间5ms内为记录分配内存时,将抛出异常。 这是我尝试添加Kafka s3-sink连接器时显示的内容。在两个kafka经纪人中有11个主题,在场的消费者已经从这些主题中消费了。我创建了一个2节点的Kafka <em
我是托管汇合卡夫卡连接器索引数据从卡夫卡到S3和Elasticsearch同时。我在Kubernetes环境中部署它,最近遇到了以下问题:-
ERROR Plugin class loader for connector: 'io.confluent.connect.elasticsearch.ElasticsearchSinkConnectorReturning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader