NPE в Kafka JDB C Исходный соединитель при использовании внутреннего запроса

Question

Я использую MYSQL5.7 и JDBCSourceConnector 5.3.x. Я использую режим пользовательского запроса, но, похоже, я не использую правильный синтаксис для выбора инкрементного столбца (Id в моем случае) в моем запросе. Это, кажется, причина для NPE, которую я отправил ниже. Я использую это как справку: https://github.com/confluentinc/kafka-connect-jdbc/issues/560

Вот конфигурация (усеченная), где я пытаюсь выбрать идентификатор добавочного столбца и другие значения конфигурации.

query= select events.eventId, events.* from (select ES.id as eventId, ES.action,  U.name FROM eventsource as ES INNER JOIN user U ON ES.user_id = U.id where U.email='xxx') events . 
mode=incrementing 
incrementing.column.name=events.eventId 
quote.sql.identifiers=never 

Может быть, пожалуйста, укажите соответствующий синтаксис для устранения этой ошибки.

java.lang.NullPointerException
    at io.confluent.connect.jdbc.source.TimestampIncrementingCriteria.extractOffsetIncrementedId(TimestampIncrementingCriteria.java:237)
    at io.confluent.connect.jdbc.source.TimestampIncrementingCriteria.extractValues(TimestampIncrementingCriteria.java:195)
    at io.confluent.connect.jdbc.source.TimestampIncrementingTableQuerier.extractRecord(TimestampIncrementingTableQuerier.java:192)
    at io.confluent.connect.jdbc.source.JdbcSourceTask.poll(JdbcSourceTask.java:316)
    at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:204)
    at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170)
    at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
[2020-01-28 14:14:37,251] ERROR WorkerSourceTask{id=connect-event-source1-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:173)