现在，我的Connect配置将其消息写入到与它正在读取的数据库表同名的主题中。是否可以指定我想要写入的确切主题？
浏览 13提问于2019-08-28得票数 1
回答已采纳
我主要想做的是使用Docker Compose拥有多个Kafka Connect实例。我想让ksqlDB使用这个集群。目前，它们都在一台机器上运行，但最终我希望将其部署到多节点环境中。我的问题是ksqlDB显然找不到Kafka Connect集群。还有KSQL_KSQL_CONNECT_URL，代表单个Kafka Connect实例的URL。-1:
image: confluentinc/cp-kafka-c
浏览 5提问于2021-05-13得票数 0
2回答
我目前正在配置kafka连接(使用)，我使用环境变量成功地将它连接到Kafka： -e CONNECT_SASL_JAAS_CONFIG="org.apache.kafka.common.security.scram.ScramLog
浏览 14提问于2022-05-24得票数 0
回答已采纳
: kafka - '9092:9092' KAFKA_BROKER_ID: 1如果我指定了特定主题的
浏览 69提问于2021-05-31得票数 0
在PostgreSQL支付(模式)发件箱(表)上配置为Kafka主题(支付-事务)。Means at Kafka Connect perform below actions
payments.outbox ==streams=> payments-transactions Topic作为新CDC流程的一部分，我们计划将webhooks(schema)发件箱(表)配置为不同的Kafka主题(Webhooks)。Means at <
浏览 1提问于2022-08-10得票数 0
在我们的docker-swarm中运行kafka connect，使用以下组成文件： cp-kafka-connect-node: external: true external: true kafka连接节点成功启动，我<e
浏览 22提问于2019-01-19得票数 1
回答已采纳
我正在尝试将一个postgreql (它是源)事件日志汇到一个已经创建和配置的kafka汇流云上。FYI，我使用quay.io/debezium/connect:1.9停靠映像作为我的kafka连接服务器，使用aws数据库作为源，使用kafka汇合云主题作为接收器。我知道属性中有CONNECT_TOPIC_CREATION_ENABLE=false = topic.creation.enable: false这样的参数可以阻止自动创
浏览 4提问于2022-05-25得票数 0
回答已采纳
我尝试通过PySpark在HBase中创建Kafka数据摄取。目前，我尝试使用HappyBase将数据从卡夫卡插入到Hbase中，但是速度非常慢。你有什么想法吗？也许是saveAsNewAPIHadoopDataset或其他任何解决方案？
浏览 18提问于2019-03-25得票数 0
我试图使用JDBC接收器连接器在Postgres中镜像一个KSQL表，但不幸的是，我无法使它工作。我正在使用Kafka 5.4.1，我有2个debezium 1.0主题与Avro连载来自我的Postgres。', KEY='id');{
"connector.class
浏览 9提问于2020-03-24得票数 1
回答已采纳
我正在尝试启动kafka模式注册表，但收到以下错误:无法将Noop记录写入kafka存储。堆栈跟踪如下所示。我检查了和动物园管理员，卡夫卡经纪人的联系-一切都很好。我可以给卡夫卡发消息。我试图删除_schema主题，甚至重装kafka，但这个问题仍然存在。昨天一切正常，但是今天，在重启我的流浪汉机器后，这个问题出现了。有什么我能做的吗？(io.confluent.kafka.schemaregistry.storage.KafkaStore:172)
浏览 9提问于2015-11-20得票数 7
到目前为止，我还没有找到任何关于配置的文档。据我想象，以下内容将复制myTopic。tasksMax = 2
topics = myTopic
浏览 4提问于2020-05-15得票数 1
然而，在"WikipediaFeed“对象中，我试图从另一个Kafka代理获取数据，而不是从启动Hello-Samza网格时运行的Kafka代理获取数据。我是否必须在"WikipediaFeed“对象中创建一个线程安全的Kafka消费者来使用来自不同Kafka集群的数据，还是有其他我看不到的方式？谢谢
浏览 6提问于2017-09-22得票数 0
1回答
我已经尝试将引导属性设置为：获取错误:在身份验证期间终止到节点-1 (/xx.xx:9092)的连接。这可能是由于以下任何原因造成的：(1)身份验证失败是由于代理的凭据无效，代理的年龄超过1.0.0；(2)防火墙阻塞Kafka TLS通信量(例如，它可能只允许HTTPS通信)；(3)瞬态网络问题。spring.kafka.properties.security.protocol=SASL_SSL
引发的抛出: java.lang.Ille
浏览 2提问于2020-03-02得票数 1
我在第一服务器使用apache kafka，在第二服务器使用apache动物园管理员。我希望在其他server.Is中有卡夫卡连接服务，可以使用独立的服务。我需要阿帕奇卡夫卡连接或融合卡夫卡连接。
浏览 7提问于2022-06-29得票数 0
2回答
是否有我可以浏览的文件？我们正计划创建50+连接器，在某一时刻，我们需要将它们从一个环境复制到另一个环境，我想知道是否有简单的方法来做到这一点。
浏览 1提问于2018-04-27得票数 0
1回答
我正在尝试使用Kafka文件脉冲连接器()将数据从文件中读取到一个Kafka主题中。..topic= logs-kafka-connect当我向test.csv添加数据时，数据不会按照配置发送到主题日志-kafka。的消息，它的行为与预期的一样，消息被添加并可以从主题中读取。因此，我似乎没有正确配置插件。
我用插件配
浏览 3提问于2021-01-01得票数 2
回答已采纳
1回答
我试图为我的Kafka指定一个主题分区。特别是，我使用的是。有大量的文档和资源与为Kafka使用者指定主题分区有关，例如：
我的理解是，Kafka基本上是一个写
浏览 6提问于2021-08-27得票数 1
回答已采纳
我们需要从Kafka中提取数据并写入AWS s3。Kafka由单独的部门管理，我们只能访问特定的主题。根据Kafka文档，看起来Kafka Connect对我来说是一个简单的解决方案，因为我没有任何自定义的消息处理逻辑。通常，当我们运行Kafka Consumer时，我们可以使用相同的使用者组运行多个JVM，以实现可伸缩性。特定消费者的消费者JVM可以运行在同一台物理服务器上，也可以运行在不同的物理服务器上。当我想使
浏览 2提问于2018-03-08得票数 1
1回答
查询:将路由器接口作为kafka集群的生产者。问题2. kafka消费者可以在不指定主题的情况下拉取数据吗？我刚刚检查了Kafka b
浏览 1提问于2014-06-18得票数 0
1回答
从Oracle增量获取
、、、
有没有办法使用JDBC的用户定义查询从Oracle数据库中获取增量数据？ 我们可以使用Spark，Kafka或者普通的JDBC。 它唯一应该能够支持重载的东西。
浏览 22提问于2019-02-28得票数 0
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
