introduced a ByteBufferInputRowParser to keep the old StringInputRowParser in places outside the KafkaFireHose