1回答
我使用汇合JDBC连接器将消息发布到主题中。源连接器将在每次轮询中向主题发送数据和架构。我想检索这个架构。我的目的是创建一个KSQL流或基于模式构建的KSQL流或表，由Kafka连接器进行投票。
浏览 0提问于2018-11-22得票数 2
回答已采纳
我用的是合流的卡夫卡码头我正在从postgresql生成数据。当我创建一个消费者并想要检索kafka消息时，它会以如下格式出现有没有办法让我以Json的身份检索它？
浏览 1提问于2020-01-23得票数 0
我正在尝试使用kafka- schema -registery api创建一个新的模式。我遵循了这篇文章中提到的步骤。Register a new avro schema using Kafka schema-registry API 我的Avro模式： {
"doc": "Sample sch
浏览 58提问于2021-03-30得票数 0
回答已采纳
我正在使用Debezium mongodb连接器来流式传输来自mongo中30 in集合的更改。" : "http://schema-registry:8081", "schema.compatibility" : "NONE"
} 首先，我
浏览 29提问于2019-02-18得票数 1
回答已采纳
因此，我正在学习Kafka，并尝试在一个docker组合文件的帮助下在本地环境中设置它。按照这个例子，我已经完成了相当多的步骤，直到我进入步骤8的后半部分。check.crcs = true connections.max.idle.ms = 540000 - CONNECT_VALU
浏览 30提问于2020-10-08得票数 0
我刚刚开始使用卡夫卡，并希望使用来查看我所拥有的各种主题。下面所示的docker-compomse.yml用于快速设置zookeeper、kafka、kafka-topics-ui，包括schema-registry和rest-proxy。问题：在localhost:8000上加载kafka-topics-ui网站，当我们单击其中一个主题时，加载进度栏就会不停地动画，并且主题的任何消息都不会出现！:8000/api/
浏览 0提问于2018-12-02得票数 0
我正在创建一个CDC Postgres.source --> Kafka / Debezium --> Postgres.sink。 源主题创建得很好，但只有在表有数据的情况下才能创建。有没有办法在没有数据的情况下实例化所有的主题？因为我想用maven命令下载所有AVRO模式： mvn schema-registry:download 我的配置： {
"name": &q
浏览 20提问于2021-07-30得票数 0
1回答
我有一个JAVA springboot项目，在kafka中推送avro消息。在我的开发过程中，使用windows PC，我所有的kafka消息都以所有特殊字符(é，à，...)显示。使用以下序列化程序：value-serializer:"io.confluent.kafka.s
浏览 41提问于2021-05-19得票数 0
回答已采纳
假设我在向kafka发送数据时使用了Avro序列化。 在使用Apache Kafka的记录时，我同时获得了模式和记录。我可以使用模式来解析记录。我不明白为什么消费者会使用不同版本的模式来反序列化记录。有人能帮帮忙吗？
浏览 12提问于2020-09-24得票数 0
我使用Mysql数据库。假设我有一张定单的桌子。并在Kafka中使用debezium mysql connect，创建了订单主题。但是我很难在ksqldb中创建一个流。CREATE STREAM orders WITH ( value_format = 'avro'KAFKA_TRANSACT
浏览 5提问于2021-06-27得票数 1
回答已采纳
2回答
正在尝试将数据从kafka写入hdfs。没有文档说明如何使用Confluent的kafka-connect-hdfs Java API。
浏览 0提问于2016-08-11得票数 3
1回答
是否有卡夫卡连接器从csv中读取并转换为Avro，然后再将其推上主题？
我已经通过了熟悉的，但它只是阅读和推动的主题。我计划修改代码库以供我的自定义使用，但在进行更改之前，我只想检查是否已经有这样的连接器可用。
浏览 2提问于2019-02-06得票数 0
1回答
由于历史原因，my-topic-1模式不是推荐的topic-value格式，而是my-custom-subject-name格式。 我想通过KSQL将记录从一个主题移动到另一个主题。首先，让我们创建一个流： CREATE STREAM my-stream-1
WITH (KAFKA_TOPIC='my-topic-1', VALUE_FORMAT='AVRO'); 糟了：- The schema is registered on a different in
浏览 17提问于2019-12-05得票数 2
然后我使用kafka连接将kafka数据汇到mysql中。
/bin/connect-独立的./etc/schema-registry/connect-avro-standalone.properties ./etc/schema-registry/connect-avr
浏览 0提问于2018-08-09得票数 1
下载合流开源3.3之后，在命令行进行一个简单的实验：confluent-3.3.0% confluent startStarting zookeeperStarting kafkaStarting schema-registryStarting kafka-rest
<em
浏览 0提问于2018-06-28得票数 0
回答已采纳
1回答
我正在与Avro/Kafka和Confluent的模式注册表Avro合作。 我使用avsc文件和avdl制作了一些具有基本类型的基本模式和主题。我正在看Confluent制作的API文档，试图将Schema升级到版本2。特别是这一部分： https://docs.confluent.io/current/schema-registry/us
浏览 29提问于2020-04-30得票数 1
回答已采纳
1回答
我们有一个kafka集群，它的Avro模式存储在Confluent的模式注册表中。在最近重新部署(我们的流应用程序之一)时，我们开始在单个主题(EmailSent)上看到不兼容的模式错误。这是唯一失败的主题，每当新的EmailSent事件提交到该主题时，我们都会收到错误。Caused by:org.apache.kafka.common.errors.Serial
浏览 0提问于2019-01-25得票数 5
2回答
我在Kubernetes集群的容器中运行了confluent kafka、zookeeper、schema-registry和ksql。Kafka，zookeeper和模式注册表工作得很好，可以创建主题并以Avro格式写入数据，但当我尝试使用curl检查ksql并创建一些流时，例如：
curl -XPOST http://ksql-svc.someapp', value_format = '<e
浏览 0提问于2018-03-18得票数 0
使用ksqlDB，我已经创建了一个带有自定义查询的JDBC连接器。然后，根据生成的kafka主题，我创建了一个表。但是，从表中选择只返回主键的数据，而返回所有其他值的null。我正在连接的postgres数据库的sales表不断更新新数据，我正尝试使用ksql流式传输这些数据。) or TUMBLING(KAFKA_STRING) or KAFKA_STRING
浏览 27提问于2020-11-30得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
