default void setByteDeserializer(Properties props) {

        final String deSerName = ByteArrayDeserializer.class.getName();

        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, deSerName);
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, deSerName);
    }
Makes sure that the ByteArrayDeserializer is registered in the Kafka properties.

@param props The Kafka properties to register the serializer in.
kafka-base/kafka-base-source/src/main/java/com/dtstack/flink/sql/source/kafka/sample/OffsetFetcher.java