036eda0c64
Based on feedback in https://github.com/debezium/debezium-server/pull/33 this commit adds the partition() method to the ChangeEvent interface and implements it in the EmbeddedEngineChangeEvent. This allows reading the assigned partition for an event in downstream processors, for example in custom Sinks that need the assigned partition for routing purposes. Link: https://issues.redhat.com/browse/DBZ-6723 |
||
|---|---|---|
| .. | ||
| checkstyle | ||
| ide-configs | ||
| revapi | ||