我正在尝试设置一个Kafka Connect Sink，以便使用Datastax连接器https://downloads.datastax.com/#akc将数据从一个主题收集到Cassandra Table中 运行直接在broker上运行的独立worker，运行Kafka 0.10.2.2-1： name=dse-sink<em
浏览 4提问于2019-12-24得票数 1
如何在apache Kafka中集成cassandra作为数据生产者？ 在kafka配置上有什么特别的配置吗？
浏览 41提问于2019-04-07得票数 0
该文件放置在路径home/kafka-connect-cassandra-接收器-1.4.0中，文件如下：connector.class=com.datastax.oss.kafka.sink.CassandraSinkConnector连接到接收器连接器，我使用了以下命令sudo kafka/config/connect-standalone.properties kafka</
浏览 3提问于2021-08-09得票数 0
回答已采纳
我使用的是kafka connect cassandra源连接器1.0版本。我在cassandra表中有一个十进制数据类型列(价格)，并将它作为json从源连接器写入到kafka主题中，它正在以某种字符串格式写入小数值，例如"price":"AA=="。现在它在我的spark流中给出错误，同时转换为float作为“数字格式异常”....？？请建议在写k
浏览 2提问于2018-11-20得票数 0
我正在尝试使用Cassandra接收器连接器读取2个kafka主题，并插入到2个Cassandra表中。我该怎么做呢？这是我的connector.properties文件：connector.class=com.datamountaineer.streamreactor.connect.cassandra.sink.CassandraSinkConnector=9042
conn
浏览 6提问于2018-02-23得票数 6
回答已采纳
我得到一个接收器cassandra连接器的运行时错误，我尝试从kafka中提取数据并将其存储在cassandra中，你会发现下面的错误堆栈： {
"name": "cassandraSinkConnector2This connector requires that records from Kafka contain the keys for the Cassandra table
浏览 12提问于2019-05-10得票数 2
我有一个Spark结构的流媒体应用程序。应用程序从kafka接收数据，并且应该使用这些值作为参数来处理来自cassandra数据库的数据。我的问题是，我如何使用输入数据帧(kafka)中的数据，作为cassandra中的"where“参数"select”，而不会出现以下错误：
Exception in thread "main" org.apache.spark.sql.A
浏览 25提问于2021-05-24得票数 0
回答已采纳
2回答
在我的星星之火结构化流应用程序中，我正在读取来自Kafka的消息，过滤它们，然后最终坚持到Cassandra。我用的是火花2.4.1。从结构化流文档中
容错语义提供端到端的精确一次语义是结构化流设计的关键目标之一。为此，我们设计了结构化流源、接收器和执行引擎，以可靠地跟踪处理的精确过程，以便它能够通过重新启动和/或重新处理来处理任何类型的故障。结合使用
浏览 0提问于2019-04-24得票数 2
我正在尝试使用kafka将所有从Sap读取的表同步到cassandra中，这是我的cassandra配置 "name": "cassandra", "transforms.ValueToKey.fields":"ROWTIME"
浏览 1提问于2018-10-25得票数 1
我注意到，如果有一个sql异常，例如，如果实际数据的长度大于实际数据的长度(定义的列长度)，任务就会停止，如果我重新启动它，同样的事情，它会尝试插入错误的条目，然后停止。它不会插入其他条目。不是一种记录错误条目并让任务继续插入其他数据的方法吗？
浏览 0提问于2019-03-15得票数 4
我是一个较新的码头，当我跟随建立一个码头形象与本地连接器，我有一些问题。步骤2/3 :复制kafka-connect-solr-接收器-0.0.1.zip/tmp/kafka-solr-接收器-0.0.1.zip-->使用缓存--> 85689e66c40a步骤3/3 :运行合流-集线器安装-不-提示符/tmp/kafka-连接-solr-接收器-0以“不提示”模
浏览 0提问于2019-08-06得票数 1
对于ETL作业，我有一个简单的场景:从Kafka主题中获取数据，并将其放到HBase表中。将来，我将在从主题中读取数据之后添加对某些逻辑的支持。我考虑两种情况：
每次数据到达卡夫卡流的窗口时写数据是一个好主意吗Kafka连接器仅由第三方开发人员支持，我不确定
浏览 0提问于2019-01-08得票数 1
我遵循了来自的教程，我能够将数据从avro控制台插入到cassandra。现在我正在尝试将其扩展到使用flume，我在我的机器中设置了flume，它将拾取日志文件并将其推送到kafka，试图将我的数据插入到cassandra数据库中。在cassandra sink中，我遇到了一个错误，
错误任务cassandra-sink-orders-0引发未捕获且不可恢复<e
浏览 3提问于2016-09-29得票数 1
我有一个需求，我需要消费Kafka Topic并将其写入MQ Topic。有人能建议我做它的最好的方法，我是新手卡夫卡。我在confluent中读过关于IBM MQ Connector的文章，但不知道如何实现它。
浏览 55提问于2019-05-28得票数 0
回答已采纳
我目前正在做一个小项目，我需要将kafka集群连接到mongodb，以便将发布到kafka主题的消息存储在mongodb数据库中。我目前有一个本地kafka集群，一个springboot生产者发布消息到一个主题，一个springboot消费者在本地消费这些消息。我也在本地安装了mongodb compass…我一直在看教程，我想我必须使用某种类型的接收器连接器( mongodb连接
浏览 1提问于2021-05-09得票数 0
我试图创建一个卡夫卡连接连接器，从一个AVRO主题到一个文件。水槽工作正常，我可以看到接收器文件正在增长，并读取数据。但是当我试图恢复到一个新的主题时，新的主题仍然没有数据。我没有错误，我已经重置了偏移量，我创建了一个新的Kafka连接并尝试恢复，我创建了一个完整的新Kafk
浏览 1提问于2019-02-08得票数 1
我正在阅读关于Kafka和Kafka Connect的文章。文档在Kafka Connect文档中以一种通用的方式提到了“Kafka源”和“Kafka汇”。我不确定这两个术语是否特定于Kafka Connect，或者它们只是指生产者和消费者。
浏览 13提问于2021-06-24得票数 0
回答已采纳
我使用的是confluent kafka连接器。我想将数据插入到接收器连接器中的特定表TB_TEST_KAFKA中。我已经创建了这个表。 auto.create=false。我不知道接收器连接器的属性、表名、键。我正在尝试插入到特定表TB_TEST_KAFKA中， connector.class=io.confluent.connect.jdbc.JdbcSi
浏览 51提问于2021-08-10得票数 0
我使用的是kafka jdbc接收器连接器，它从主题插入数据到SQL Server数据库。由于mssql中的某些问题，连接器已停止，并出现错误：
Caused by: org.apache.kafka.connect.errors.ConnectException: com.microsoft.sqlserver.jdbc.SQLServerException我的问题是，一旦SQL Server启动，我当前的
浏览 4提问于2020-04-03得票数 1
我在用debezium捕获mysql中的数据时遇到了问题，将数据捕获并使用kafka连接jdbc接收器将其消费到另一个mysql。因为debezium对kafka主题产生的模式和有效负载与kafka连接jdbc接收器所期望的模式不兼容。
当jdbc接收器想要使用数据并在另一个mysql中创建记录时，我就会异常。
浏览 2提问于2017-05-14得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
