public static long consumerRecordSizeInBytes(final ConsumerRecord<byte[], byte[]> record) {
        return recordSizeInBytes(
            record.serializedKeySize(),
            record.serializedValueSize(),
            record.topic(),
            record.headers()
        );
    }
@throws StreamsException if the admin client request throws an exception
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java