使用Kafka Connect (6.1.1)，我正在尝试使用调整我的Kafka消息，然后再将它们放入BigQuery (使用BigQuerySink)。transforms.scriptenginetransformer.type=seko.kafka.connect.transformer.script.ScriptEngineTransformervalueTransform(source){
浏览 11提问于2021-06-07得票数 0
回答已采纳
在设置源连接器和接收器连接器之后，我会发现DATE类型Postgres列的问题。全堆栈跟踪： at org.apa
浏览 1提问于2019-12-03得票数 2
回答已采纳
我尝试使用"transform“为我的数据创建插件，以便kafka-connect并将其与不同的接收器连接器一起使用。当我安装插件时，kafka-connect看不到我的类。我使用kafka-connect maven插件来创建我的捆绑包zip。使用confluent-hub (从本地文件)安装已成功
浏览 31提问于2019-08-29得票数 1
我想使用JSON和没有模式的JDBC接收器连接器。他们编写()：
key.converter=org.apache.kafka.connect.json.JsonConverter value.converter=false
当
浏览 9提问于2021-07-16得票数 2
回答已采纳
1回答
弹簧启动嵌入式卡夫卡无法连接
、、、、
我已经完成了测试，但是当我开始测试时，我只看到这个重复的无限的结果：
我在我的@EnableKafka类上有了@Configuration注释。${SCHEMA_REGISTRY_URL
浏览 1提问于2019-04-03得票数 5
回答已采纳
我尝试通过Landoop UI创建twitterSourceConnector，但create按钮被禁用。name=twitter-sourcetopic=twitter-source-demo
浏览 1提问于2019-07-24得票数 2
我正在使用docker容器来构建zookeeper，kafka和connect。- zookeeper
image: debezium/connect portsto error [org.apache.kafka.connect.cli.ConnectDistributed]
kafka
浏览 139提问于2020-10-18得票数 1
无法在Spring Cloud Stream Binder Kafka 3.x (functional style)中将自定义商店连接到我的Transformer，如here中的示例所示。context) { this.myStore = context.getStateStore(storeName);
} 当应用程序上下文从我的单元测试启动时: state store my-store added to topology
浏览 31提问于2021-04-06得票数 0
回答已采纳
我正在尝试评估kafka confluent platform 4.0版。但是，当我在kafka集群上启用ssl时，kafka-connect启动失败。详细的日志记录如下：
[2017-12-18 04:38:55,747] ERROR Uncaught exception in herder work thread, exiting: (org.apache.kafka.connect.runtime.distributed.Di
浏览 88提问于2017-12-18得票数 1
我正在尝试设置Kafka Connect，目的是运行ElasticsearchSinkConnector。
Kafka设置，由3个代理组成，使用Kerberos、SSL和ACL进行安全保护。到目前为止，我已经尝试在本地使用docker/docker-compose (Confluent docker-image 5.4 with Kafka 2.4)连接到远程kafka-installat
浏览 0提问于2020-04-06得票数 8
回答已采纳
我使用FlinkKafkaConsumer从Kafka读取数据，然后将数据转换为表，最后用FlinkSQL将接收器数据返回到kafka(kafka-连接器表)。为了得到准确的一次交付保证，我用属性设置了kafka表:sink.emantic=精确-一次。当进行测试时，我得到了错误“事务超时大于代理允许的最大值”。Flink默认Kafka生产者最大事务超时: 1h
卡夫卡默认<em
浏览 10提问于2022-07-01得票数 0
回答已采纳
我在使用Go解析静态/动态YAML文件时遇到了一些问题。这是我正在使用的YAML文件 #this part is fixed platformName: 'default' KAFKA_CONNECT_enable: false
KAFKA_CONN
浏览 32提问于2020-07-04得票数 0
我在独立模式下使用Elastic search Kafka连接。我并不困惑于使用哪种配置来启动Kafka，连接并从上一个故障点恢复。例如，生产者将继续将记录推送到Kafka和Consumer中，因为Elastic Search接收器连接器正在消耗，现在由于某种原因，我的消费者关闭了，但我的prouder仍将继续将消息推送到Kafka现在，当我修复了ES接收器连接器一侧的问题，如果我重启ES接收器连接器，它应该从最后一个失败中挑选，而不
浏览 20提问于2020-01-22得票数 0
回答已采纳
我正在使用Kafka Connect加快速度。尝试使用Kafka Connect Elasticsearch Service接收器连接器将我们的数据从Kafka移动到Elasticsearch。我有一个处理流，看起来像这样： 来自S3的文件记录->来自发布到->kafka主题的源应用程序的自定义处理->Kafka连接->弹
浏览 23提问于2021-04-07得票数 0
回答已采纳
1回答
如何开启Kafka源连接器幂等性功能？
我知道在confluent中，我们可以通过worker配置中的producer.*属性覆盖生产者配置，但是Kafka本身呢？是一样的吗？设置这些配置后，我可以在哪里看到我的connect worker的应用配置？
浏览 1提问于2021-01-22得票数 1
3回答
启动Kafka连接(connect-standalone)后，我的任务在启动后立即失败： at java.nio.HeapByteBuffer:222) atorg.apache.kafka.conn
浏览 263提问于2017-02-01得票数 30
回答已采纳
我们已经成功地使用了使用jdbc独立连接器的mySQL - kafka数据吞并，但是在分布式模式下(作为kafka连接服务)，我们现在面临着同样的问题。连接-分发.属性文件-group.id=connect-cluster/usr/share/java&
浏览 2提问于2018-11-15得票数 0
回答已采纳
2回答
我正在尝试使用Spring Cloud和Kafka Avro序列化程序在Kafka上生成一个事件。在我的application.yml中，我有下面的配置，但是当序列化程序试图生成消息时，它会生成字节，因为在KafkaSerializer中传递给getScheme方法的对象是一个字节数组，而不是GenericRecord我想在Spring Cloud中我需要一个特定的MessageConverter，但是我没有找到。cloud:
str
浏览 0提问于2018-11-01得票数 0
看起来，如果我们喜欢在分布式模式下设置Kafka连接器，那么我们需要在CONNECT_REST_ADVERTISED_HOST_NAME上有一个惟一的主机名。但是，如果我们使用自动缩放组将连接器部署在AWS上，那么就没有已知的主机名了，不确定如何进行安装？
浏览 6提问于2021-12-14得票数 0
回答已采纳
2回答
我一直试图使用与SASL_SSL连接到Kafka集群。我已将jaas.conf文件传递给执行者。我似乎无法设置密钥库和信任库身份验证的值。我试着传递thisspark 中提到的值还是没有运气。: Failed to construct kafka consumer
at org.apache.kafka.clients.consumer.KafkaConsumer.", "SA
浏览 0提问于2020-02-28得票数 3
回答已采纳
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
