我尝试了官方的示例(消费者/生产者)与我本地安装的confluent 4.0.0，它可以在发送post请求和在侦听器中接收时发送“传感器”avro消息，但当我使用confluent 4.0.0附带的kafka- avro -console-consumer工具查看发送的avro消息时，该工具引发了以下错误(a)。我也尝试使用kafka- avro -console-pro
浏览 3提问于2018-08-26得票数 1
1回答
我正试图使用apache-kafka二进制文件中的kafka-控制台-生产者来生成消息，并在春季启动时从消费者设置中消费。使用者使用avro架构。当以json格式生成消息时，我的使用者抛出异常--“无法序列化”。
我找到了一个解决方案来使用“7.1”，其中有kafka-avro-console-producer。它支持a
浏览 6提问于2022-04-26得票数 0
回答已采纳
2回答
我们需要手动缓存模式注册表吗？
、、、、
我们目前正在使用协议缓冲区作为kafak消息的序列化机制。我们要搬到阿夫罗去。我们用Schema测试了Avro汇合消费者，根据这些测试，Avro使用者与原型消费者相比有点慢。我用的是confluent_kafka AvroConsumer。
浏览 0提问于2018-05-04得票数 0
回答已采纳
在我的用例中，我已经创建了JDBC kafka连接器，从oracle表中提取数据并成功地推送到kafka主题，但是当我尝试从这个kafka主题中读取消息时，我得到如下所列的反序列化问题。org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 2
浏览 20提问于2019-03-23得票数 2
回答已采纳
我一直在尝试与kafka-avro-console-consumer从Confluent连接到我们的遗留Kafka集群，该集群是在没有Confluent Schema Registry的情况下部署的。我使用如下属性显式地提供了模式： --topic test \--property key.schema='{"type"
浏览 2提问于2018-09-19得票数 6
回答已采纳
我正在学习Avro模式序列化的基础知识。我理解，键和值都可以有它们特定的Avro模式。然而，我感到困惑的是序列化过程实际上是如何工作的。或者，在向主题发布
浏览 5提问于2022-11-17得票数 0
回答已采纳
你好，im正在(反)序列化一个简单的avro模式和模式注册中心。序列化的消息，其中包括更新和验证模式。然后，使用者应该将消息反序列化为具有接收到的架构的对象。使用ConfluentRegistryAvroDeserializationSchema。my.awesome.MyExampleEntity-value", "id":
浏览 9提问于2021-06-01得票数 1
假设我在向kafka发送数据时使用了Avro序列化。 在使用Apache Kafka的记录时，我同时获得了模式和记录。我可以使用模式来解析记录。我不明白为什么消费者会使用不同版本的模式来反序列化记录。有人能帮帮忙吗？
浏览 12提问于2020-09-24得票数 0
1回答
为了满足服务的可靠性，我需要使用kafka-smallrye和quarkus将无法反序列化的所有传入消息推入死信主题。主题上的所有消息都应该是avro格式(但我不能确定)，在模式注册中心上有一个定义模式。我已经以这样的方式设置了我的使用者的配置： messaging: test-in:
connector: smallrye-kafkaSystem.out.println(schema
浏览 11提问于2020-11-12得票数 1
回答已采纳
我试图从logstash发送消息到KAFKA到HDFS。
} kafka {
codec => <e
浏览 10提问于2016-06-08得票数 4
我正在构建一个微服务组件，默认情况下，它将消耗由其他组件(SCS)生成的Stream (SCS) Kafka消息。 group: input-scs-group
使用上面的配置，我可以使用SCS默认配置创建两个使用者，例如，类org.apache.kafka.com
浏览 0提问于2018-08-08得票数 5
回答已采纳
msg = kafka_consumer.poll(timeout=2.0)
如何通过Python confluent-kafka api<e
浏览 2提问于2016-07-07得票数 0
我试图用avro消息生产者、kafka和avro消费者构建一个使用spring引导、spring云流模式注册表和kafka绑定器的工作示例。在使用消息时会发生以下错误：
错误7059 --afka-侦听器-1 o.s.c.s.b.k.KafkaMessageChannelBinder :无法使用contentType java.lang.NullPointerException反序列化io.igx.android.S
浏览 6提问于2017-03-09得票数 1
1回答
我正在尝试听一个话题，这个话题是我使用confluent的kafka连接功能发布的。但是，我无法对其进行反序列化。我相信它的avro序列化，但不能找到正确的反序列化。消息如下所示，如控制台主题所示
null {"c1":{"int":10},"c2":{"string":"foo"},"create_ts":1552598863000,"
浏览 1提问于2019-03-15得票数 1
我正在尝试设置一个使用python 从Kafka读取的束管道。我能够设置使用者配置和主题。如何更新管道以使用合流模式注册表并定义Avro消息值反序列化器？
浏览 2提问于2021-06-08得票数 0
我是KAFKA协议世界的新手，我想问你一些与我的项目相关的重要信息。我正在使用AVRO文件来生产和消费消息，我想知道是否可以将相同的avro文件用于多个主题，例如，通过在生产者中使用不同的"name“属性，以及在使用者中使用特定的"name”属性。
非常感谢。
浏览 0提问于2018-07-20得票数 0
2回答
我有一个使用者，它使用两个不同的avro模式的两个主题。将来主题的数量可能会增加，因此合并要从多个主题读取的架构是不可伸缩的。from confluent_kafka import Consumer
msg = consumer.poll()
msg_value = message.value() #Should be in bytes or s
浏览 2提问于2022-07-29得票数 0
回答已采纳
我们使用模式注册表来存储模式，消息被序列化到avro，并被推送到kafka主题。
浏览 8提问于2020-05-06得票数 5
",当我为s3接收器运行Kafka连接器时，我会收到以下错误消息我的模式只包含一个数组类型字段，其模式如下
{"name":"item_id","type":{"type":"array","items":["
浏览 0提问于2018-10-29得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
