我已经为记录创建了一个Avro模式，我们将其发布到我们的Kafka主题。我们实际的Kafka记录模式要复杂得多，但为了简洁起见，我只是附上了相关的部分。我们在记录中有多个嵌套的子类，但由于某些原因，我在尝试发布记录时得到以下异常(包名称已被隐藏)： java.lang.ClassCastException: aaa.bbb.ccc.ddd.Amountcannot be cast to org.apache.avro.generic.IndexedRecord class KafkaRecord {
浏览 20提问于2019-04-24得票数 0
我在尝试用一个简单的ClassCastException程序测试Avro模式演化时，得到了一个Java。", "fields": [ "name": "Cus
浏览 0提问于2020-08-30得票数 1
回答已采纳
我们正在努力将Apache Storm与Kafka的Confluent框架集成在一起。Kafka消息中Avro数据的Avro模式是通过使用HTTP GET从Confluent的模式注册表中获得的。我将Kafka消息中的schema和Avro数据放入两个文件中，下面是我的测试程序：import avro_json_serializer as ajs
import json, avro
浏览 1提问于2016-03-01得票数 0
value.deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer key.serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
value.serializer: io.confluent.kafka.serializers.KafkaAvroSerializer我必须产生消息从卡夫卡控制台生产者例如- kafka-consol
浏览 2提问于2021-01-28得票数 0
", "key.converter.enhanced.avro.schema.support": "http://xx.xx.xx/schema/",
"value.converter.enhan
浏览 11提问于2020-12-16得票数 1
回答已采纳
当我创建一个消费者并想要检索kafka消息时，它会以如下格式出现
codesc�����[�c81e728d9d0.9.4.Finalpostgresqlconektatestdb��ך���KЗ���
浏览 1提问于2020-01-23得票数 0
在主题创建部分之前，一切都很好：docker exec -i schema-registry /usr/bin/kafka-avro-console-producer -\avro\input_movie_event.avsc'docker exec -i schema-registry /usr/bin/kafka-avro-console-produ
浏览 5提问于2022-04-05得票数 0
回答已采纳
This could eiorg.apache.kafka.connect.errors.DataException: JsonConverter with schemas.enable requires "schema" and "payload" fields and may not contain additionainternal.v
浏览 0提问于2017-07-03得票数 1
我试图理解Kafka Streams API是如何与Schema Registry一起工作的。我知道在设置应用程序时必须指定Schema Registry URL，但我无法理解如果不指定主题名称或ID，应用程序如何从注册表检索正确的模式。
它使用主题名称检索模式？
浏览 2提问于2019-11-25得票数 2
我希望返回一个扩展avro模式的对象，并将HATEOAS链接添加到响应中。我做了一些调查，结果发现我需要对象的自定义序列化程序。当前对象是avro模式的扩展。ObjectMapper();}
其中用户数据是实际的avro此外，是否有更好的方法返回一个avro对象与其他参数相结合？
浏览 3提问于2020-03-16得票数 5
我一直在尝试与kafka-avro-console-consumer从Confluent连接到我们的遗留Kafka集群，该集群是在没有Confluent Schema Registry的情况下部署的。我使用如下属性显式地提供了模式： --topic test \--from-beginning \
--property ke
浏览 2提问于2018-09-19得票数 6
回答已采纳
1回答
我使用jdbc source connector从oracle获取数据，并将( avro格式的键和值(模式注册表))推到kafka主题。Value schema:"subject": "testtopicA-value","id": 1122,
"schema": "{\"type\":\"record\",\"name\&quo
浏览 4提问于2022-03-31得票数 0
2回答
反序列化Avro消息
、、、、
container_name: kafka-postgres - ksql-server - schema-registry", "kafka.topic": "pageviews但由于错误而失败：
2020-02
浏览 0提问于2020-02-01得票数 3
回答已采纳
编辑from kafka import KafkaConsumerimport avro.schemaimport requests)) schema = avro.schema.parse(schema)
bytes_reader
浏览 4提问于2016-09-14得票数 3
回答已采纳
我一直在尝试阅读Kafka的avro串行化消息，这些消息来自于Scala2.11的火花结构化流(2.4.4)。为此，我使用了星星之火-avro(下面的依赖性)。{"name": "string_field","type": "string"}}from time import sleep的问题是，我在pyt
浏览 0提问于2020-02-29得票数 2
回答已采纳
我正在尝试使用kafka- avro -console-consumer以log4j格式打印关于kafka主题的avro消息。为此，我使用以下kafka-avro-console-consumer命令：
bin/kafka-avro-console-consumer --bootstrap-server localhost:9092 --topic avro-test -property print.key=true --
浏览 0提问于2018-07-18得票数 1
我正在尝试使用PySpark 2.4.3阅读Kafka的Avro消息。基于下面的堆栈over flow链接，可以转换为Avro格式(to_avro)，并且代码正在按预期工作。_jvm.org.apache.spark.sql.avro return_jvm.org.apache.spark.sql
浏览 1提问于2019-11-21得票数 1
1回答
是否有卡夫卡连接器从csv中读取并转换为Avro，然后再将其推上主题？
我已经通过了熟悉的，但它只是阅读和推动的主题。
浏览 2提问于2019-02-06得票数 0
, bootstrap_servers=KAFKA_HOSTS, api_version=KAFKA_VERSION)
print('Lead =我正在使用avro转换器产生数据到主题(Debezium)。我试过互联网上的一些转换器。但这些都不起作用。其中一个是这样的 bytes_reader = io.BytesIO(consumer)reader = a
浏览 39提问于2021-01-27得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号