ConsumeRecords

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