我有一个spring boot web服务，它使用XML文件，向MQ生成JSON，但是，由于XSD schema中的标记和它们创建的后续XMLElementRef对象，我在解组XML时遇到了困难。作为一种变通方法，我制作了一个定制的JAXB element序列化器，ObjectMapper使用它将这些XML转换为JSON。
问题出现在Kafka的配置需要序列化程序。config.p
浏览 12提问于2018-12-12得票数 1
回答已采纳
3回答
我正在尝试使用Spring Cloud Stream来集成Kafka。正在编写的消息是Java POJO，虽然它的工作方式与预期一样(消息正在写入主题，我可以使用消费者应用程序读取)，但消息的开头添加了一些未知字符，这在尝试集成Kafka Connect以接收主题中的消息时会造成麻烦在默认设置下，这是推送到Kafka的消息：
contentType "text/plain"
浏览 1提问于2017-11-21得票数 3
回答已采纳
我们正在考虑在我们的消息传递中使用Kafka，我们的应用程序是使用Spring开发的。因此，我们计划使用spring-kafka。 kafka: producer:
浏览 0提问于2018-06-29得票数 5
回答已采纳
2回答
我有一个包含不同值类型的嵌套键的示例JSON数据，例如整数、浮点数和字符串： "ordertime": 1497014222380, "itemid、AVRO或Protobuf序列化这个示例JSON数据。是否有用于Python或Node的生成器库可以将JSON数据对象作为三个序列化程序(如JSON_SR、AVR
浏览 13提问于2022-08-04得票数 0
回答已采纳
我知道另一种选择是轮询JobRepository (在我的情况下这很好)，但我不想使用它。spring.kafka.producer.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer
spring.kafka.consumer.key-deserializerorg.springframework.kafka.support.serializer.J
浏览 7提问于2021-08-10得票数 0
回答已采纳
1回答
我正在构建一个Java应用程序，其中有一些JSON对象(特别是来自com.satori.rtm.model.AnyJson的AnyJson对象)，我想在主题中发送这些对象。我之所以这样问，是因为构造函数KafkaProducer<K, V>在(反)序列化时处理JSON值时似乎遇到了一些问题。);在来自org.springframework.<em
浏览 0提问于2018-06-06得票数 0
11回答
在库更新之前的Spring / Kafka应用程序中，我使用以下类org.telegram.telegrambots.api.objects.Update将消息发送到Kafka主题。现在我使用以下org.telegram.telegrambots.meta.api.objects.Update。如你所见-他们有不同的包裹。ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
pr
浏览 2提问于2018-08-04得票数 36
回答已采纳
2回答
我是卡夫卡的新手。我正在尝试发送一条消息到Kafka主题，其中包含头部和有效载荷。void sendMessageToKafkaTopic(@RequestBody CabLocationPayload cabLocationPayload) { Header和Payload具有Json但是使用ClassCastException还是失败了。:无法将类org.apache.kafka.common.serialization.StringSerializer的值转换为在value.ser
浏览 468提问于2021-04-22得票数 0
1回答
我使用的是具有以下属性的kafka消费者： key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
value.deserializer=org.apache.kafka.connect.json.JsonDeserializer KafkaProducer(value.serializer=org.apache.kafka.connect.json</
浏览 58提问于2021-08-20得票数 0
回答已采纳
1回答
这是我第一次使用卡夫卡，我计划在.net中使用卡夫卡。我想知道在生成事件时是否可以发送JSON作为消息另外，是否有一种方法可以将该值映射到模型，以便value/json结构始终绑定到该模型？例如:如果我希望我的json值是 "customerName":"anything",
浏览 2提问于2021-11-23得票数 0
回答已采纳
当我创建使用者并试图反序列化对象时，我得到了错误。由: IllegalArgumentException:类'com.domain.project2.package2.SomeEvent‘不在受信任的包中: java.util、java.lang、com.domain.project2我的.yml配置： kafka: producer:
key-serializer:org.apa
浏览 3提问于2020-02-14得票数 0
回答已采纳
如何使用kafka-console-producer在kafka topic中插入json文件数据？每个json数据集可以存储为一条消息吗？last_name": "Lindt", "gender": "Male",}
如果您使用<
浏览 2提问于2019-02-13得票数 11
3回答
我正在使用kafka和spring引导，我需要将JSON对象发送到kafka，重点是我能够以JSON的形式发送对象，配置KafkaTemplate，但只为这个对象发送。;import对象呢？我
浏览 2提问于2020-09-03得票数 1
回答已采纳
data-ingest可以根据我的判断工作，因为它向主题external_messages发送消息。关于该主题的消息示例： serializer: org.springframework.kaf
浏览 2提问于2021-06-05得票数 0
回答已采纳
我正在试用芭蕾舞演员，想知道我们是否可以有一个芭蕾舞演员节目，这是一个卡夫卡消费者可以暴露为AWS Lambda函数。
浏览 37提问于2019-05-02得票数 1
我对Springboot和Kafka非常陌生。在学校作业中，我们需要使用Springboot应用程序发布关于Kafka主题的Json数据。--partitions
1 --topic Kafka 然后，我使用以下命令启动一个使用者： bin/kafka-console-consumer.sh --bootstrap-serverlocalhost:9092 --topic Kafka --from-
浏览 27提问于2020-03-17得票数 0
我使用Kafka生成器连续向Kafka主题发送CSV行，并生成以下形式的CSV行流：
temp=23.3, pressure=1015, humidity=63.4, windspeed=7.4....现在，我想使用ESPER在这个流上执行复杂的事件处理，但是Esper使用预定义的POJO类并使用EPL语句来过滤事件。如何在运行时将CSV流转换为事件流，以便Esp
浏览 1提问于2018-07-24得票数 0
(我一直在更改后缀，以避免任何可能的混淆，并手工创建主题，因为否则我会收到警告，STREAM_TOPIC_IN_xxx=LEADER_NOT_AVAILABLE和流将在一分钟左右内不运行。)第一个侦听器和流似乎正在工作，但是当STREAM_OUT_TOPIC上的侦听器试图反序列化消息时，我会得到下面的异常。我正在为流中的服务器提供Produced.with。为了使侦听器知道要反序列化到的类型，我需要做什么？value-serializer: org.springframework.kafka</e
浏览 0提问于2019-03-11得票数 17
回答已采纳
我刚接触Kafka (使用Spring Boot 2.2.4)，我看到了一些示例，其中KafkaTemplate是字符串，字符串只是发送字符串。我正在考虑发送Json对象，我看到有两种不同的方法……一些人使用String，Object，还有一些人使用String，TheActualModelClass。
这两者之间有没有利弊？我假设主要的区别是类型化的模板只适用于一个模型，而对象可以向任何主题发送任
浏览 0提问于2020-02-01得票数 1
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
