KafkaMetricsDataDeserializer.java 640 B

123456789101112131415161718192021222324
  1. package com.usthe.alert.entrance;
  2. import com.usthe.common.entity.message.CollectRep;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.apache.kafka.common.serialization.Deserializer;
  5. /**
  6. * MetricsData的反序列化
  7. * @author tom
  8. * @date 2021/11/24 17:29
  9. */
  10. @Slf4j
  11. public class KafkaMetricsDataDeserializer implements Deserializer<CollectRep.MetricsData> {
  12. @Override
  13. public CollectRep.MetricsData deserialize(String topicName, byte[] bytes) {
  14. try {
  15. return CollectRep.MetricsData.parseFrom(bytes);
  16. } catch (Exception e) {
  17. log.error(e.getMessage(), e);
  18. }
  19. return null;
  20. }
  21. }