Hi,
Generally you can't do it using Ignite KafkaStreamer API because it's
not so flexible to configure the KafkaConsumer used inside.
Generally it supported in
https://kafka.apache.org/0110/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#seek(org.apache.kafka.common.TopicPartition,%20long)
but can't be configured. You can create the JIRA ticket for it.
However, you can try to configure it using Kafka scripts like it
described here:
https://stackoverflow.com/questions/29791268/how-to-change-start-offset-for-topic
BR,
Andrei
12/3/2019 1:07 PM, ashishb888 пишет:
I want to start from a specific offset of the Kafka partition, it is possible
with KafkaStreamer?
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
