当我想要发送一条AVRO消息，其中包含一个类型为long的字段时，我得到了以下错误：Caused by: java.lang.ClassCastException: java.lang.Longcannot be cast to org.joda.time.DateTime</em
浏览 36提问于2017-12-18得票数 5
回答已采纳
1回答
我从使用avro模式的kafka获得这个字段：我有这样的Dto： private LocalDateTime time;
我正在尝试将字段dateTime转换为curren
浏览 9提问于2022-10-23得票数 0
回答已采纳
:60)Caused by: org.apache.kafka.common.errors.SerializationException: Error deserializing AvroAvro message for id -1
Caused by: java.io.EOFException
浏览 0提问于2019-08-02得票数 0
我一直在尝试与kafka-avro-console-consumer从Confluent连接到我们的遗留Kafka集群，该集群是在没有Confluent Schema Registry的情况下部署的。--from-beginning \ --property value.schema='{"type":"<e
浏览 2提问于2018-09-19得票数 6
回答已采纳
我已经用Pyspark构建了Spark结构化流流程，它从kafka主题读取avro消息，进行一些转换，并将数据作为avro加载到目标主题中。我使用ABRIS包()与Schema集成，从汇合式序列化/反序列化Avro。"null", ],},
此过程引发以下错误：Cannot convert Catalyst type IntegerType to Avro我
浏览 0提问于2020-07-28得票数 3
我试着用“kafka - avro -console-producer”将json转换为avro，并将其发布到kafka主题。我能够完成那个平面json / schema的操作，但是对于给定的模式和json，我得到了"org.apache.avro.AvroTypeException: union分支EventId“错误。name": "Value",
浏览 3提问于2021-02-25得票数 1
回答已采纳
1回答
我已经将kafka连接到mysql。该主题包含AVRO格式的数据。现在，我想将该数据转换为CSV格式。为此，我使用了KSQL流。当我像这样创建流时(如果我用相同的主题运行消费者命令，它会显示数据)，然后给select * from source_avro，它不会显
浏览 1提问于2019-04-23得票数 1
我使用的是logstash avro插件。{ "type": "long",然后我在java端有avro生成的DTO，我将其转换成ByteArray我的kafka配置是可以的，它使用By
浏览 5提问于2018-01-29得票数 0
5回答
我已经能够在KV (Long，String)这样的简单场景中使用如下内容来消费消息：但当你需要从AVRO反序列化时，这似乎不是一种方法。我有一个KV(STRING，AVRO)，我需要使用它。我尝试从AVRO模式生成Java类，然后将它们包含在“应用”中，例如：
PCollection<MyClass&g
浏览 7提问于2019-02-19得票数 2
2回答
反序列化Avro消息
、、、、
我从部署了卡夫卡。": "pageviews", "fields": [ "name": "viewtime", } "connect.name": "ksql.pa
浏览 0提问于2020-02-01得票数 3
回答已采纳
Key format : STRINGValue format : AVROKafka topic : turnstile_summary_1 (partitions: 2, replication: 1)
----------------------------------------
CTAS_TURNSTILE_SUMMARY_6 : CREATE
浏览 8提问于2020-02-03得票数 0
此时模式注册表为空：[]而不是执行：
docker exec -i schema-registry /usr/bin/kafka-avro-console-producer:从D:\
浏览 5提问于2022-04-05得票数 0
回答已采纳
根据我对avro的理解，所有avro记录都会附带一个模式。kafka生产者将数据转换为字节数组并发送给kafka使用者。使用者返回发送的数据。我的问题是，如何在不引入模式注册概念的情况下，从kafka使用者那里检索模式。有没有一种方法可以不使用模式注册表从kafka使用者那里获得模式？
浏览 3提问于2017-06-16得票数 2
回答已采纳
嗨，我正在尝试将我从kafka获得的通用记录转换为我想要使用的特定对象。event = (TxnEngineEvent) SpecificData.get().deepCopy(TxnEngineEvent.SCHEMA$, consumerRecord.value()); 从Long(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String, org.apache.avro.generic
浏览 44提问于2020-07-21得票数 2
1回答
我想了两个想法：2)从;import org.apache.kafka.clients.producer.ProducerConfig");
//props.put(&
浏览 1提问于2017-06-07得票数 1
could eiorg.apache.kafka.connect.errors.DataExceptionat org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:309)
下面是我的StandaloneConfiginternal.value.converter = class org.apach
浏览 0提问于2017-07-03得票数 1
我们正在使用kafka，并将avro模式和模式注册表设置为FULL兼容性。": [ "name": "created_at", "null", "type": "long版本来说，这很好，因为它依赖于avro-python3 1.8。但是，最近的confluent-kafka依
浏览 9提问于2021-12-10得票数 5
2回答
我正在编写一个Kafka连接器，以便从Github上的多个来源下载一些数据(文本和yaml文件)，并将它们转换为某个类的对象，这些对象是从avsc文件自动生成的： { {"name": "type", "type": "string"},
{"name&q
浏览 11提问于2019-06-04得票数 1
回答已采纳
key.converter“和"value.converter”没有配置，因此转换使用Avro完成。"key.converter.schemas.enable":"false"，"value.converter.schemas.enable":"false"，
"fields: [{"name" : "user_id", "
浏览 1提问于2022-07-23得票数 0
我目前正致力于从avro模式生成连接模式。("parquet.avro.write-old-list-structure", false);Exception in thread "main" org.apache.kafka.connect.errors.DataException: Mismatch
浏览 11提问于2022-10-07得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
