Can't log the record here because there is none...
|
if (index < 0 || index >= data.count()) { |
|
this.logger.warn(batchListenerFailedException, () -> |
|
String.format("Record not found in batch: %s-%d@%d; re-seeking batch", |
|
record.topic(), record.partition(), record.offset())); |