APISonar


io.confluent.kafkarest.converters.AvroConverter.JsonNodeAndSize.json

> io > confluent > kafkarest > converters > AvroConverter > JsonNodeAndSize > json
io APIs confluent APIs kafkarest APIs converters APIs AvroConverter APIs JsonNodeAndSize APIs json APIs

Example 1
public ConsumerRecordAndSize<JsonNode, JsonNode> createConsumerRecord(
      MessageAndMetadata<Object, Object> msg) {
    AvroConverter.JsonNodeAndSize keyNode = AvroConverter.toJson(msg.key());
    AvroConverter.JsonNodeAndSize valueNode = AvroConverter.toJson(msg.message());
    return new ConsumerRecordAndSize<>(
            new AvroConsumerRecord(msg.topic(),
                                   keyNode.json,
                                   valueNode.json,
                                   msg.partition(),
                                   msg.offset()),
            keyNode.size + valueNode.size
    );
  }
Example 2
public ConsumerRecordAndSize<JsonNode, JsonNode> createConsumerRecord(
      ConsumerRecord<Object, Object> record) {
    AvroConverter.JsonNodeAndSize keyNode = AvroConverter.toJson(record.key());
    AvroConverter.JsonNodeAndSize valueNode = AvroConverter.toJson(record.value());
    return new ConsumerRecordAndSize<JsonNode, JsonNode>(
        new AvroConsumerRecord(record.topic(), keyNode.json, valueNode.json, record.partition(),
            record.offset()),
        keyNode.size + valueNode.size
    );
  }