我尝试了官方的示例(消费者/生产者)与我本地安装的confluent 4.0.0，它可以在发送post请求和在侦听器中接收时发送“传感器”avro消息，但当我使用confluent 4.0.0附带的kafka- avro -console-consumer工具查看发送的avro消息<
浏览 3提问于2018-08-26得票数 1
我一直在尝试与kafka-avro-console-consumer从Confluent连接到我们的遗留Kafka集群，该集群是在没有Confluent Schema Registry的情况下部署的。我使用如下属性显式地提供了模式： --topic test \--property key.sch
浏览 2提问于2018-09-19得票数 6
回答已采纳
我试图用avro消息生产者、kafka和avro消费者构建一个使用spring引导、spring云流模式注册表和kafka绑定器的工作示例。在使用消息时会发生以下错误：
错误7059 --afka-侦听器-1 o.s.c.s.b.k.KafkaMessageChannelBinder :无法使用contentType java.
浏览 6提问于2017-03-09得票数 1
1回答
我正试图使用apache-kafka二进制文件中的kafka-控制台-生产者来生成消息，并在春季启动时从消费者设置中消费。使用者使用avro架构。当以json格式生成消息时，我的使用者抛出异常--“无法序列化”。
我找到了一个解决方案来使用“7.1”，其中有kafka-avro</em
浏览 6提问于2022-04-26得票数 0
回答已采纳
1回答
我试图了解如何使用与卡夫卡绑定的Spring流。让我们从Stream示例中获取。
AVRO架构位于src/resources/avro中。当运行mvn:c
浏览 0提问于2021-09-20得票数 1
回答已采纳
我有一个使用Spring-Kafka的Spring Boot应用程序，我使用docker中的landoop's fast-data-dev作为我的kafka集群。我使用kafka模板、avro和confluent的模式注册表生成到一些主题的消息。但是，当我进入快速数据开发ui时，我可以看到我的
浏览 33提问于2019-05-06得票数 0
4回答
我有一个问题，反序列化来自卡夫卡主题的信息。这些消息已经使用spring云流和Apache序列化。我正在使用Spring阅读它们，并试图对它们进行反序列化。如果我同时使用spring来生成和使用消息，那么我可以很好地反序列化这些消息。问题是当我用Spring消费它们，然后尝试反序列化。我在这个主题上发送
浏览 0提问于2019-01-30得票数 3
回答已采纳
2回答
我希望有一个Spring的通用使用者，在这里我不需要在编译时指定Avro消息的模式。由于消息中包含模式id，所以应该可以使用模式id将其反序列化为对象或一般记录(这可以轻松地在框架之外完成)。为了做到这一点，我尝试使用与我们以前使用的方法相同的方法，即使用带有特定记录的spring云流
浏览 1提问于2019-08-21得票数 0
回答已采纳
1回答
我试图使用函数编程(和spring云流)从输入主题转换输入AVRO消息，并在输出主题上发布新消息。我尝试过非AVRO输入的转换，它工作得很好。
创建名为‘kafkaStreamsFunctionProcessorInvoker’的bean时出错</
浏览 5提问于2021-04-06得票数 1
2回答
在批处理模式下获取消息头
、、、
在春季云流卡夫卡应用程序中，当以常规模式使用消息时，我会正确地获得带有有效负载和自定义头的消息。然而，当我将使用者"headerMode“设置为true，将函数的输入类型设置为List<?> (根据文档)时，我会得到一个有效负载列表。如何获得包含头和有效负载的消息列表？当设置集合类型时(例如，List<Message<MyType
浏览 20提问于2021-12-05得票数 0
我正在编写一个使用Avro消息的spring云流接收器应用程序。我试图让应用程序使用这些消息，但是我得到了以下错误。=0, kafka_receivedTopic=bam_hrapi, kafka_receivedTimestamp=-1, contentType=avro/bytes}], failedMessage=0, kafka_received
浏览 1提问于2018-09-19得票数 1
我正在尝试阅读卡夫卡主题中的最后一条消息，使用ConsumerSeekAware.Message类型是Avro列表。我能成功地做到这一点。但在反序列化过程中，它是失败的。这条消息是使用spring云流-kafka框架生成的。我知道avro消息可以反序列化如下所示。消息是avro对象的列表。但是
浏览 4提问于2017-09-28得票数 1
我正在使用spring云流kafka绑定器和模式注册表。(不是kakfa流)我要做的是，当不可反序列化消息进入输入主题时，将deserializable消息发送到dlq.。所以我尝试了像下面这样的配置，但是spring应用程序让不断地无限地重试，并且说
由: org.apache.kafka.common.errors.Serialization
浏览 3提问于2021-02-18得票数 0
回答已采纳
我使用弹簧云流:3.2.2弹簧云流绑定卡夫卡:3.2.5 spring-cloud-stream-binder-kafka-streams:3.2.5
我想在反应性编程中写出消费者卡夫卡。我使用avro模式注册表。在我的例子中，我在一个主题中输入了多个事件。我的使用者使用所有类型，但我想在每个事件类型中编写一个使用者。在您<em
浏览 10提问于2022-09-30得票数 0
当从Kafka输入主题读取具有唯一Avro模式的消息类型A时，我让服务A执行操作A，当从相同主题读取消息类型B时，服务B执行操作B。 我不希望服务A知道B的模式，反之亦然。如果我有两个单独的主题，我会很容易地将spring.kafka.properties.specific.avro.reader设置为true并在特定记录中消费，但是由于我不希望模式B出现在服务A
浏览 7提问于2020-12-07得票数 0
回答已采纳
我正在使用avro生成一个java类( Heartbeat )，并且我正在使用Spring云消息处理器，以便通过此Heartbeat类将消息推送到kafka。因此，消息如预期的那样出现了。我也从我的heartbeatKafkaConsumer收到一条消息，但是当我执行断言时，我得到了这个错误： <"ConsumerRecor
浏览 1提问于2021-05-28得票数 0
有没有可能会丢失一些消息，如果我们使用雪花kafka连接器。例如，如果kafka连接器读取消息并在消息写入variant表之前提交偏移量，那么我们将丢失该消息。如果我们使用kafka connect，会出现这种情况吗？
如果您有任何示例，也欢迎这些示例，谢谢！
浏览 0提问于2019-12-04得票数 2
我正在使用spring云流并试图发布avro消息，但是得到了上述异常，spring.cloud.stream.bindings.feed-output-channel.producer.useNativeEncodingspring.cloud.stream.kafka.binder.producer-properties.value.serializer=io.confluent.kafka.s
浏览 14提问于2022-01-21得票数 0
回答已采纳
1回答
当我尝试使用我各自的模式对数据运行时，它返回错误"AvroRuntimeException:格式错误的数据。长度为负：-40“。我看到其他人也遇到过类似的问题：、和。它一直运行到这部分代码(第73行)我已经尝试了其他解码器，并打印出了avro变量的内容，我相信你会期望序列化的byteArrayInputStream数据看起来是什么样子(
浏览 0提问于2016-03-16得票数 11
回答已采纳
2回答
我想知道是否允许它生成具有JSON键模式和AVRO值模式的消息。 对生产者记录的混合和匹配模式类型有限制吗？ 模式注册中心会禁止它吗？这被认为是一种糟糕的做法吗？
浏览 22提问于2020-08-20得票数 0
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
