仅在一个消费微服务上无法AVRO序列化

Question

我有五个Kafka消费服务和一个Kafka生产服务。我在每个Java消费微服务的消费者库中推出了一个新的avro模式。我还没有做出制片人方面的改变。但其中一个消费服务无法序列化任何内容，其他四个工作正常。

我有个例外

java.lang.RuntimeException: java.lang.ClassNotFoundException: com.sun.ws.rs.ext.RuntimeDelegateImpl
    at javax.ws.rs.ext.RuntimeDelegate.findDelegate(RuntimeDelegate.java:122)
    at javax.ws.rs.ext.RuntimeDelegate.getInstance(RuntimeDelegate.java:91)
    at javax.ws.rs.core.UriBuilder.newInstance(UriBuilder.java:69)
    at javax.ws.rs.core.UriBuilder.fromPath(UriBuilder.java:111)
    at io.confluent.kafka.schemaregistry.client.rest.RestService.getId(RestService.java:656)
    at io.confluent.kafka.schemaregistry.client.rest.RestService.getId(RestService.java:642)
    at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getSchemaByIdFromRegistry(CachedSchemaRegistryClient.java:217)
    at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getSchemaBySubjectAndId(CachedSchemaRegistryClient.java:291)
    at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getSchemaById(CachedSchemaRegistryClient.java:276)
    at io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer$DeserializationContext.schemaFromRegistry(AbstractKafkaAvroDeserializer.java:273)
    at io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer.deserialize(AbstractKafkaAvroDeserializer.java:97)
    at io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer.deserialize(AbstractKafkaAvroDeserializer.java:87)
    at io.confluent.kafka.serializers.KafkaAvroDeserializer.deserialize(KafkaAvroDeserializer.java:62)

在生产者和消费者方面发生变化的一些事情是kafka-avro-序列化器的版本到6.0.0
kafka-客户端到2.0.0

因此，到达该消费者的记录为空，并且在我们的配置中阻塞了我们的队列，我们不推进手动偏移。

希望你能帮上忙。

Answer 1

您需要包括jersey客户端库。

您可以手动或根据您的构建工具添加. jar：

Maven

<dependency>
    <groupId>org.glassfish.jersey.core</groupId>
    <artifactId>jersey-client</artifactId>
    <version>3.0.0</version>
</dependency>

Gradle

compile group: 'org.glassfish.jersey.core', name: 'jersey-client', version: '3.0.0'

SBT

libraryDependencies += "org.glassfish.jersey.core" % "jersey-client" % "3.0.0"

...

（...）