Debezium codebase has many occurrences of this pattern:

try {
  [...]
} catch (InterruptedException e) {	
  Thread.interrupted();
  [...]
}

The intent is to restore the interrupt flag, however Thread.interrupted(); does not do that. It just checks whether there is currently the flag set (and clears is as a side-effect)

The right set the interrupt flag on it's own thread is Thread.currentThread().interrupt()