I am using the couchbase kafka connector (https://github.com/couchbase/couchbase-kafka-connector) and I am trying to start the connector from a defined point and not stop after that.
ConnectorState start = connector.startState(); ConnectorState end = connector.endState(); connector.run(start, end);
This starts froms the very beggining and works ok. But when the code changes to:
ConnectorState start = connector.startState(766); ConnectorState end = connector.endState(); connector.run(start, end);
It throws an exception:
java.lang.IllegalArgumentException: partitions in FROM state do not match partitions in TO state
Any ideas how to solve it?
Thanks in advance
PD: The state of the connector is saved in a file. We implemented one StateSerializer.