You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@ignite.apache.org by ashishb888 <as...@gmail.com> on 2019/12/03 10:07:51 UTC

Manage offset of KafkaStreamer

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/

Re: Manage offset of KafkaStreamer

Posted by ashishb888 <as...@gmail.com>.

Noted. Thank you Andrei.



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: Manage offset of KafkaStreamer

Posted by Andrei Aleksandrov <ae...@gmail.com>.

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/