使用 Ga特林将 avro 消息推送到 kafka 时遇到问题

问题描述 投票:0回答:1

嗨,我正在关注 tinkoff GitHub 处理 avro 消息时出现以下错误

e! (您正在使用3.9.5) 12:28:36.374 [警告] o.a.k.c.p.ProducerConfig - 这些配置“[schema.registry.url]”已提供,但尚未使用。 12:28:36.850 [警告] o.a.k.c.p.ProducerConfig - 这些配置“[schema.registry.url]”已提供,但尚未使用。 模拟 ru.tinkoff.gadling.kafka.examples.AvroClassWithRequestReplySimulation 开始... 12:28:37.238 [错误] r.t.g.k.a.KafkaRequestAction - “kafkaRequest-1”因“o.a.k.c.e.SerializationException”而崩溃:无法将类 java.lang.String 的密钥转换为密钥中指定的类 org.apache.kafka.common.serialization.ByteArraySerializer .serializer',转发到下一个

任何人都可以提供正确的文档来使用 Gabling 将 avro 消息推送到 kafka

apache-kafka sbt scala-gatling gatling-plugin
1个回答
0
投票

您是否得到此异常的答案或解决方案?

© www.soinside.com 2019 - 2024. All rights reserved.