我正在使用一个自定义的Kafka反序列化程序，它从JSON中封送一个对象。value.deserializer" -> "com.mystuff.CustomJSONDeserializer"new KafkaConsumer[Array[Byte], MyMessage](props)
我见过的一件事是，如果有人在主题中发布了不好的JSON，Kafka会尝试使用我的自定义反
浏览 6提问于2016-07-29得票数 2
我创建了一个Spring引导应用程序，它将消息发送到Kafka队列(使用spring集成kafka支持)。我想发送任意的json序列化对象。有没有办法在我的spring boot应用程序中获得/注入json-de-/序列化程序？或者如何即席反/序列化一个对象？
应用序列化有哪些好的实践？
浏览 1提问于2018-01-29得票数 0
2回答
即使在特定配置之后，Spring流也不会在反序列化错误上重试。期望是，它应该基于配置的重试策略重试，最后将失败的消息推送到DLQ。 }
metadataRetryOperations在KafkaTopicProvisioner.java中总是为null，因此它在afterPropertiesSet()中创建了一个新的RetryTemplate
浏览 1提问于2019-06-26得票数 0
回答已采纳
我有一个基于Kafka的Smallrye reactive messaging的Quarkus项目。因为我想使用一个“复杂的pojo”，所以我需要一个自定义的反/序列化程序。我想让这两个类成为CDI bean，这样我就可以注入和使用我的自定义记录器，它是一个CDI bean。有没有办法做到这一点？现在，我的注入记录器对象是简单的
浏览 0提问于2020-06-25得票数 2
1回答
我正在尝试(反)序列化一个对象，该对象的属性具有来自maven依赖项的类型，因此我不能更改此类型的类。此类型的类具有@JsonSerialize和@JsonDeserialize注释。但是，我希望使用默认的序列化程序和反序列化程序，因为自定义序列化程序写入的是数组而不是对象。有没有办法，使用注
浏览 1提问于2017-05-12得票数 0
我将相关角色的消息(反)序列化到Play /从Play序列化！杰森。我想使用JSON (反)序列化的akka持久化系统(如果可能)。
在文档中，可以使用我们自己的序列化程序。此外，还提供了如何编写自定义序列化程序的说明。既然期望使用toBinary和fromBinary，有没有办法将Play JSON
浏览 3提问于2015-01-27得票数 4
1回答
我一直在玩一个基本的动物园管理员和卡夫卡的设置，以学习如何使用它，但我有麻烦的消费者。当Kafka不可用时，对poll()方法的调用将挂起，直到它重新联机。stopped) { // until Kafka is back: records) {
proce
浏览 0提问于2018-05-10得票数 4
回答已采纳
我使用SpringKafka2.2.8并尝试使用AlwaysRetryPolicy实现无限重试策略，并且我创建了一个自定义SeekToCurrentErrorHandler来捕获反序列化过程中的异常、消息键和值generic record }以下是我的自定义RetryPolicy和
浏览 3提问于2020-03-11得票数 0
回答已采纳
我有以下kafka生产者属性。MyEventSerializerdefault.value.serde=MyEventSerde 我已经了解了Vertx site中的序列化程序Supported types are: String, Short, Integer, Long, Float, Double, ByteArray, ByteBuffer, Bytes 有没有办法在Vertx kafka</
浏览 20提问于2019-02-07得票数 0
case类，如下所示：其中Parcelable没有扩展Serializable，但有一种方法可以返回自身的ByteArray(实现了Serializable的东西)。如何使case类可序列化？有没有办法对特定字段进行自定义(反)序列化？
(我现在正在通过创建一个简单的可序列化的包装器类并
浏览 3提问于2012-03-04得票数 3
我可以将我的数据以字符串的形式保存到Kafka，如下所示：，但是有没有办法将我的case类直接保存到Kafka中呢？例如，如果我想以case类ModbusMessage的形式保存我的数据。
如果有
浏览 0提问于2017-01-18得票数 1
我正在尝试更改我的一个类中列表的(反)序列化。我如何从jackson那里获得必要的类？所有默认的jackson序列化程序都有一个这样的构造函数：protecte
浏览 4提问于2012-09-07得票数 1
回答已采纳
1回答
我的Spark应用程序从Kafka接收二进制数据。数据被作为字节原型消息发送到Kafka。proto消息是：使用ScalaPB库，我可以将Any消息反序列化为其原始格式。如何将值从字节反序列化为可读格式？SerializationUtils不工作。这就是Any消息反序列化后的样子。该值仍为其字节格式。使用Seriali
浏览 9提问于2021-03-17得票数 0
回答已采纳
自定义反/序列化程序，键是一个简单的字符串@StreamListener }
这在反序列化错误中失败，在调试之后，我看到原因是消息的内容类型标头被设置为application/json，因此它试图将消息反序列化为JSON。内容类型标头是如何设置<em
浏览 0提问于2019-07-15得票数 1
回答已采纳
1回答
刚刚意识到我的管道是错误的，当涉及到错误事件时，它们一直在被处理，并且从未从订阅中删除。 ...当错误发生时，我会在流水线上一次又一次地看到相同的</em
浏览 1提问于2020-01-08得票数 0
回答已采纳
我正在开发一个Spring引导应用程序。该应用程序充当Kafka-producer，其中生产/发布消息并不是很重要。我的应用程序显示以下日志 17:18:45.187 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClientwhile fetching metadata with correlation id 15 : {aksubd=UN
浏览 245提问于2021-08-12得票数 1
我们正在尝试实现下面描述的用例，我们有我们希望克服的实现问题，我们正在尝试通过匹配两个流的消息中存在的关键字(JSON)来在两个Kafka主题之间进行KStream连接。此外，我们应该维护消息序列，因为它是从源文件到达KStream的。
场景是，如果匹配的键还没有到达任何一个流，我们应该停止或重试join，直到预期的键到达其他主题。我们想把不匹配的记录放回KStream，但在这种情况下，不
浏览 2提问于2019-05-08得票数 2
我正在尝试创建一个具有可定制背景的appwidget。我使用NinePatchDrawable，并且我想更改它的颜色(使用setColorFilter方法)。这在活动中是没有问题的，但是对于用于appwidget的RemoteView对象，这似乎是不可能的。
有没有办法让应用小部件中的ImageView更新为新的可绘制图形，而不是位图？或者，如果没有，也许可以获得应用程序小部件的实际大小，并将彩色N
浏览 3提问于2010-11-08得票数 0
回答已采纳
我正在开发一个asp.net mvc-5 web应用程序，我使用的是ap.net版本4.5。在我的web应用程序中，我正在执行一些power-shell脚本，以获取一些有关服务器和VM的硬件信息，并返回代码中的结果，如下所示：System.StackOverflowException was unhandled
An unhandled excepti
浏览 1提问于2016-11-25得票数 6
回答已采纳
我实现了SessionAwareListener接口来创建自定义侦听器，对业务逻辑重用了旧代码。有没有办法控制DMLC重试消息的频率，以及如何处理未捕获的异常？
浏览 3提问于2012-05-11得票数 7
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
