我正在寻找合适的教程/指南的java kafka-stream与模式注册表。我有谷歌，但找不到合适的教程。如果有人能帮我找到至少合适的教程，我真的很感激。我可以找到googling.But的kafka stream教程，我正在寻找带schemaregistry的kafka stream
浏览 12提问于2019-06-10得票数 0
1回答
项目描述如果我删除模式注册表中的现有模式，然后重试，将auto.register.schemas设置为true，那么它将显示它为我生成的模式schema: &quo
浏览 4提问于2021-08-31得票数 0
回答已采纳
我试图用avro消息生产者、kafka和avro消费者构建一个使用spring引导、spring云流模式注册表和kafka绑定器的工作示例。在使用消息时会发生以下错误：
错误7059 --afka-侦听器-1 o.s.c.s.b.k.KafkaMessageChannelBinder :无法使用contentType java.lang.NullPointerException反序列化io.igx.
浏览 6提问于2017-03-09得票数 1
1回答
我试图使用函数编程(和spring云流)从输入主题转换输入AVRO消息，并在输出主题上发布新消息。我尝试过非AVRO输入的转换，它工作得很好。
我的困难是如何在application.yaml文件或spring应用程序中声明模式注册表。我尝试过许多不同的配置(似乎很难找到正确的文档)，每次应用程序都找不到schema.registry.url的设置。: http://localh
浏览 5提问于2021-04-06得票数 1
1回答
我使用带有avro序列化的kafka：springendpoint: http://127.0.0.1:8081
我还使用avro-tools-1.8.1.jar生成了类。现在我正在尝试读取和转换来自kafka</em
浏览 20提问于2017-02-19得票数 0
1回答
我很难弄清楚如何测试使用Avro作为消息格式和(合流)模式注册表的应用程序。order: valueSerde: io.confluent.kafka.streams.serdes.avro.GenericAvroSerdeoutput: valueSerde: io.confluent.kafka</e
浏览 0提问于2019-07-31得票数 1
回答已采纳
1回答
我使用汇合JDBC连接器将消息发布到主题中。源连接器将在每次轮询中向主题发送数据和架构。我想检索这个架构。我的目的是创建一个KSQL流或基于模式构建的KSQL流或表，由Kafka连接器进行投票。
浏览 0提问于2018-11-22得票数 2
回答已采纳
当我们通过KSQL创建AVRO消息并尝试使用Kafka来使用它们时，会发生一些奇怪的事情。有一点背景：
源数据第三方提供商正在我们的一个卡夫卡集群上生成数据，作为JSON (到目前为止，非常好)。在某些上下文中，我们使用多个Kafka Connect集群(这些集群具有相同的属性)，因此我们为这些数据运行了Kafka Connect集群，但对于其他AVRO数据则是集群的精确副本(1用
浏览 1提问于2019-10-31得票数 0
回答已采纳
2回答
我在Kubernetes集群的容器中运行了confluent kafka、zookeeper、schema-registry和ksql。Kafka，zookeeper和模式注册表工作得很好，可以创建主题并以Avro格式写入数据，但当我尝试使用curl检查ksql并创建一些流时，例如：
curl -XPOST http://ksql-svc.someappvarchar) WITH (kafka_topic = 'kawab
浏览 0提问于2018-03-18得票数 0
1回答
我正在尝试读取存储在S3中的avro记录，以便使用confluent提供的S3源代码将它们放回卡夫卡主题中。我已经有了具有正确模式的主题和注册表设置，但是当连接S3源代码试图将我的记录序列化到主题时，我会得到以下错误
org.apache.kafka.common.errors.SerializationException:错误注册Avro模式引起的：.在io.c
浏览 7提问于2022-07-07得票数 0
回答已采纳
我是flink和Kafka的新手。我正在尝试使用Confluent Schema注册表对avro数据进行反序列化。我已经在ec2机器上安装了flink和Kafka。运行flink可执行jar的命令： ./bin/flink run -c com.streaming.example.ConfluentSchemaRegistryExample /opt/flink-1.7.2/kafka-flink-<e
浏览 43提问于2019-04-22得票数 1
我正在使用spring 2.6.3 EmbeddedKafka和Junit 5编写一个spring引导集成测试，用于使用avro消息的拓扑结构。在测试中我使用的是MockSchemaReigstryClient
我正在注册模拟模式客户端，并按照现在关闭的中的建议配置主题。(KafkaAvroDeserializer.java:55) ~[kafka-avro-serializer-
浏览 9提问于2021-01-10得票数 3
我试图使用avro模式在ksqldb中创建一个流到Kafka中的某个主题。该命令如下所示：主题客户看起来如下:使用命令打印‘客户’；
密钥格式：¯_(ツ)_/-无数据处理值格式: JSON或KAFKA_STRING行时: 2022&#x
浏览 10提问于2022-09-29得票数 0
回答已采纳
我已经创建了一个NiFi流，它最终将json记录发布为带有Avro编码值和字符串键的记录，使用模式中的模式。这是 in NiFi。我现在试图使用Kafka (connect-standalone)使用JdbcSinkConnector将消息移动到PostgreSQL数据库，但得到了以下错误：insert.mode=
浏览 0提问于2018-12-11得票数 0
回答已采纳
kafka2.12-2.4.0融合5.4.1plugin.path=/usr/local/tools/confluent-5.4.1/share/java,/usr/local/tools/kafka/kafka_
浏览 0提问于2020-04-23得票数 0
我最近开始探索卡夫卡和卡夫卡的联系，并做了一些初步的设置。但是想了解更多关于模式注册部分的内容。因此，基本上我如何执行AVRO模式和测
浏览 1提问于2020-01-06得票数 3
我正在开发一个带有火花流的简单java。我能够正确地阅读主题：
null {"id":1557，"ip":
浏览 0提问于2019-04-09得票数 2
回答已采纳
1回答
我有一个关于使用Kafka以及主题(Kafka broker)和主题(Schema Registry)的不同名称设置流处理器的问题。代理和模式注册表似乎一切正常，但是如果处理器接收到事件，模式注册表魔术就开始了。将发送abc.bla，而不是将abc作为主题发送到模式注册表。模式注册表的回答是not found。我想知道出了什么问题，因为单个生产者
浏览 44提问于2021-11-15得票数 0
1回答
我使用jdbc source connector从oracle获取数据，并将( avro格式的键和值(模式注册表))推到kafka主题。当我启动流时，我开始获得ClassCastException: java.lang.Long cannot be cast to org.apache.avro.generic.GenericRecord由connect生成的模式具有数据类型为"long“的</em
浏览 4提问于2022-03-31得票数 0
我使用的是databricks运行时10.0和Spark3.2.0和Scala2.12。我还依赖于io.confluent:kafka-schema-registry-client:6.2.0，，使用CachedSchemaRegistryClient在模式注册表中注册模式，如下所示：import io.confluent.kafka.schemaregistry.a
浏览 5提问于2022-03-03得票数 1
回答已采纳
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
