我正在将来自卡夫卡主题的消息存储在KeyValueStore中，以便以后查询它们。：spring.cloud.stream.kafka.streams.bindings.input: consumer: materializedAs: all-messagesvalue-serializer: com.me.MyMessageSerializer
但是，当我从KeyValueStore读取键时，键作为String正确地返回，但是返回<
浏览 1提问于2019-07-03得票数 1
回答已采纳
我正在尝试使用来自kafka主题的消息，其中json的内容没有序列化。这个主题是用实际的JSON生成的，没有序列化，如下所示。case_id": "500g000000Tw5ggAAB", "state_of_origin": "CA"
}
浏览 13提问于2022-08-08得票数 0
Kafka Streams程序在什么情况下需要序列化/反序列化？假设我们有以下简单的程序：Kstream<k,v> stream2 = stream.filter( predicateA )stream3.to( topic );
具体地说，在filter的两次调用之间，"k“和"v
浏览 0提问于2018-09-14得票数 0
我试图理解Kafka Streams API是如何与Schema Registry一起工作的。我知道在设置应用程序时必须指定Schema Registry URL，但我无法理解如果不指定主题名称或ID，应用程序如何从注册表检索正确的模式。
它使用主题名称检索模式？
浏览 2提问于2019-11-25得票数 2
我创建了一个Spring引导应用程序，它将消息发送到Kafka队列(使用spring集成kafka支持)。我想发送任意的json序列化对象。有没有办法在我的spring boot应用程序中获得/注入json-de-/序列化程序？或者如何即席反/序列化一个对象？
应用序列化有哪些好的实践？
浏览 1提问于2018-01-29得票数 0
你好，im正在(反)序列化一个简单的avro模式和模式注册中心。设置：
目标:生产者应该发送一条用ConfluentRegistryAvroSerializationSchema序列化的消息，其中包括更新和验证模式。然后，使用者应该将消息反<em
浏览 9提问于2021-06-01得票数 1
1回答
例如，我们有一个用例，在该用例中，我们以格式A接收来自主题的数据，但希望将其流到两个位置，一个是格式A，另一个是格式B。在一个连接器中可以做到这一点吗？
浏览 1提问于2017-10-12得票数 0
回答已采纳
1回答
为了满足服务的可靠性，我需要使用kafka-smallrye和quarkus将无法反序列化的所有传入消息推入死信主题。主题上的所有消息都应该是avro格式(但我不能确定)，在模式注册中心上有一个定义模式。我已经以这样的方式设置了我的使用者的配置： messaging: test-in:
浏览 11提问于2020-11-12得票数 1
回答已采纳
我不明白不能反序列化的消息是如何用spring写到DLT主题的。
我根据配置了使用者，这对于消息反序列化后出现的异常非常有效。但是，当消息不可反序列化时，将在轮询消息时抛出org.apache.kafka.common.errors.SerializationException。随后，使用此异常调用SeekToCurrentEr
浏览 3提问于2020-02-18得票数 2
回答已采纳
如文档所述，实例的主机和端口是通过application.server在每个实例中配置的。当在实例重新启动的测试环境中运行应用程序时，streams.metadataForKey返回一个host+port组合(正如我用这个键发送消息所期望的那样)。当我通过REST查询返回的keyValueStore.get(key)实例上的状态存储时，streams.metadataForKey将返回本地实例的application.server值(
浏览 10提问于2022-07-31得票数 1
我有一个要求，在Kafka中，我们将把一堆不同提供商的财务价格反馈到一个单独的“市场数据”主题中。问题是，这些提供商中的一些人有细粒度的许可要求，甚至到个人证券。在不为每个不同的许可粒度创建不同的主题的情况下，有没有一种方法可以防止Kafka客户端根据消息中的内容接收信息？即Kafka可以做细粒度的主题
浏览 10提问于2019-06-30得票数 2
回答已采纳
1回答
Avro -反序列化POJO
、、、、
我刚认识阿夫罗，卡夫卡花了几天时间发送卡夫卡主题的序列化数据.没有成功。在制片端，我通过SOAP接收数据，并发送关于Kafka主题的内容。我使用CXF从WSDL生成POJO，并编写了相应的模式。我要做的是序列化由CXF解封的对象，并将它们发送到我的Kafka主题中。在web上发现的</e
浏览 4提问于2015-05-26得票数 1
我正在学习Avro模式序列化的基础知识。我理解，键和值都可以有它们特定的Avro模式。然而，我感到困惑的是序列化过程实际上是如何工作的。
在创建主题时是否指定要使用的Avro模式？这样，生产者就可以使用纯文本发布消息，kafka服务器知道如何序列化/反序列化消息。同样，使用者可以以普
浏览 5提问于2022-11-17得票数 0
回答已采纳
2回答
我们有基于域的不同服务。所有这些服务都通过Rest(Sync)和Kafka (异步)进行通信。这是因为所有服务都依赖于这个公共库，但是库将使用者记录值作为string(字符串反序列化器)，然后根据委托给相应处理程序的消息</
浏览 6提问于2022-09-27得票数 1
根据我的理解，通常我们将在kafka主题中使用模式来处理消息序列化/反序列化，并且通常我们在模式注册表中注册我们的模式，下面是一些有关这方面的问题：
如果我的团队还没有构建模式注册中心，我们还能在kafka主题和消息中使用模式吗？我们必须在合流模式注册表中构建模式注册表还是可以在我们公司的gitlab.com环境中构建
浏览 1提问于2020-10-30得票数 1
卡夫卡消息的有效载荷中有什么方法可以给我一个时间戳头吗？我想检查消息何时在使用者端创建，并在此基础上应用自定义逻辑。编辑
我正在设法将一些自定义值(基本上是时间戳)附加到由生产者发布的消息，以便能够在特定的时间内使用消息。现在，卡夫卡只需确保信息会按照他们被排在队列中的顺序发送。但在我的例子中，以前生成的记录可能会在一定的延迟后到达(因此，在时间上生成的<
浏览 3提问于2013-09-11得票数 2
我正在使用spring-cloud-stream kafka绑定器来消费来自kafka主题的消息。源系统正在以ascii发送json消息。当我的消费者听到它抛出的主题时
o.s.c.s.b.k.KafkaMessageChannelBinder : Could not convert message: 7B22736..我可以在.yml文件中设置什么属性来反序列化它吗？或者有
浏览 0提问于2017-03-08得票数 1
我仍然无法理解卡夫卡生产者/消费者和模式注册中心是如何重用KafkaProperties的。还是不打算重用相同的结构？因此，对于模式注册表，我必须配置以下属性：
spring.kafka.basic.auth.credentials.sourcespring.kafka.basic.auth.user.infospring.kafka.producer.properties.schema.registry.urlspring.kafka.consumer.properties.
浏览 5提问于2021-06-24得票数 1
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
