ConsumeRecords

constructor(format: RecordFormat, timeout: Duration? = null)(source)