CsCallister

No solution yet ? I have run into the same issue. Note that since the error is thrown by the sink connector we can not use errors.tolerance=all property cause it...

Because I did not find any solution on this I decided to go with a dirty hack : https://docs.confluent.io/platform/current/connect/transforms/filter-confluent.html In the connector configuration I added : transforms: filterSpammer transforms.filterSpammer.type: io.confluent.connect.transforms.Filter$Value...