static Deserializer getDeserializer()

in pulsar-client-kafka-compat/pulsar-client-kafka/src/main/java/org/apache/pulsar/client/kafka/compat/KafkaProducerInterceptorWrapper.java [251:269]

• 19 lines of code
• 8 McCabe index (conditional complexity)

    static Deserializer getDeserializer(Serializer serializer) {
        if (serializer instanceof StringSerializer) {
            return new StringDeserializer();
        } else if (serializer instanceof LongSerializer) {
            return new LongDeserializer();
        } else if (serializer instanceof IntegerSerializer) {
            return new IntegerDeserializer();
        } else if (serializer instanceof DoubleSerializer) {
            return new DoubleDeserializer();
        } else if (serializer instanceof BytesSerializer) {
            return new BytesDeserializer();
        } else if (serializer instanceof ByteBufferSerializer) {
            return new ByteBufferDeserializer();
        } else if (serializer instanceof ByteArraySerializer) {
            return new ByteArrayDeserializer();
        } else {
            throw new IllegalArgumentException(serializer.getClass().getName() + " is not a valid or supported subclass of org.apache.kafka.common.serialization.Serializer.");
        }
    }