DBZ-1583 Propagate Replicator exception to Kafka Connect
This commit is contained in:
parent
13c6c67a1d
commit
c25bb23a04
@ -154,7 +154,7 @@ public void start(Configuration config) {
|
|||||||
@Override
|
@Override
|
||||||
public List<SourceRecord> poll() throws InterruptedException {
|
public List<SourceRecord> poll() throws InterruptedException {
|
||||||
if (replicatorError != null) {
|
if (replicatorError != null) {
|
||||||
throw new ConnectException("Failing connector task, at least one of the replicators has failed");
|
throw new ConnectException("Failing connector task, at least one of the replicators has failed", replicatorError);
|
||||||
}
|
}
|
||||||
List<SourceRecord> records = queue.poll();
|
List<SourceRecord> records = queue.poll();
|
||||||
recordSummarizer.accept(records);
|
recordSummarizer.accept(records);
|
||||||
|
Loading…
Reference in New Issue
Block a user