...
public void putBrokenRecord(Collection<SinkRecord> var1) {
throw UnsupportedOperationException(); // This"Broken record handling is thenot defaultsupported implementationby to indicate that broken record handlingthis connector"); // This is notthe supported by this connectordefault implementation.
}
Connectors can overwrite this function to handle broken records.
...