kafka.message.Message.isValid()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(1.5k)|赞(0)|评价(0)|浏览(205)

本文整理了Java中kafka.message.Message.isValid()方法的一些代码示例,展示了Message.isValid()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.isValid()方法的具体详情如下:
包路径:kafka.message.Message
类名称:Message
方法名:isValid

Message.isValid介绍

暂无

代码示例

代码示例来源:origin: apache/incubator-pinot

  1. private Iterable<MessageAndOffset> buildOffsetFilteringIterable(final ByteBufferMessageSet messageAndOffsets,
  2. final long startOffset, final long endOffset) {
  3. return Iterables.filter(messageAndOffsets, input -> {
  4. // Filter messages that are either null or have an offset ∉ [startOffset; endOffset[
  5. if (input == null || input.offset() < startOffset || (endOffset <= input.offset() && endOffset != -1)) {
  6. return false;
  7. }
  8. // Check the message's checksum
  9. // TODO We might want to have better handling of this situation, maybe try to fetch the message again?
  10. if (!input.message().isValid()) {
  11. LOGGER.warn("Discarded message with invalid checksum in partition {} of topic {}", _partition, _topic);
  12. return false;
  13. }
  14. return true;
  15. });
  16. }

代码示例来源:origin: HomeAdvisor/Kafdrop

  1. private MessageVO createMessage(Message message, MessageDeserializer deserializer)
  2. {
  3. MessageVO vo = new MessageVO();
  4. if (message.hasKey())
  5. {
  6. vo.setKey(ByteUtils.readString(message.key()));
  7. }
  8. if (!message.isNull())
  9. {
  10. final String messageString = deserializer.deserializeMessage(message.payload());
  11. vo.setMessage(messageString);
  12. }
  13. vo.setValid(message.isValid());
  14. vo.setCompressionCodec(message.compressionCodec().name());
  15. vo.setChecksum(message.checksum());
  16. vo.setComputedChecksum(message.computeChecksum());
  17. return vo;
  18. }

相关文章