Hello, Could you please help me with the following issue?
I have an installed vertica cluster (3 hosts) and installed apache kafka cluster on 3 other hosts. I have scheduler that reads data from kafka topic. This scheduler worked correctly but stopped processing new messages a few days ago. In vertica log I see the following error:
2020-07-07 13:00:15.087 com.vertica.solutions.kafka.scheduler.StreamCoordinator::Main [INFO] Starting frame @ 2020-07-07 13:00:15.087
2020-07-07 13:00:28.905 com.vertica.solutions.kafka.scheduler.LaneWorker::Lane Worker 1 (MB:750001-FRAME@2020-07-07 13:00:15.087) [ERROR] Rolling back MB: [Vertica][VJDBC](8361) ERROR: NULL value detected in partition group by expression
java.sql.SQLDataException: [Vertica][VJDBC](8361) ERROR: NULL value detected in partition group by expression
at com.vertica.util.ServerErrorData.buildException(Unknown Source)
at com.vertica.dataengine.VResultSet.fetchChunk(Unknown Source)
at com.vertica.dataengine.VResultSet.initialize(Unknown Source)
at com.vertica.dataengine.VQueryExecutor.readExecuteResponse(Unknown Source)
at com.vertica.dataengine.VQueryExecutor.handleExecuteResponse(Unknown Source)
at com.vertica.dataengine.VQueryExecutor.execute(Unknown Source)
at com.vertica.jdbc.common.SPreparedStatement.executeWithParams(Unknown Source)
at com.vertica.jdbc.common.SPreparedStatement.executeUpdate(Unknown Source)
at com.vertica.solutions.kafka.scheduler.Microbatch.execute(Microbatch.java:350)
at com.vertica.solutions.kafka.scheduler.LaneWorker.run(LaneWorker.java:67)
at java.lang.Thread.run(Thread.java:748)
With kafkacat, I read messages correctly (I execute the command from the host where the scheduler is running):kafkacat -C -b 192.168.0.10:9092 -t mytopic -o -1 -e
{"replyOn":"a112e","source1":{"name":"mysource1","version":"1.0.3"},"source2":{"name":"mysource2","version":"0.8.9.3"}}
Why is that?