I have used Confluent provided JdbcSinkConnector to consume messages from a topic to Oracle table. The connector ran fine but no data loaded to the sink due to data type mismatch. Though the execution is not successful but the connect-consumer group’s current offset and end offset value are same. Why was end offset value of the connect-consumer updated?
So I reset the offset value of connect-consumer as “to-earliest” and ran the connector again but no message was consumed by the connector this time. Why is it so? (Note: My topic has 35 messages and Offset value of connect-consumer is current: zero, end: 35 & lag:35)
What should I need to do if I want to consume the messages from beginning?