There is typo in your consumer configuration, it should
be auto.offset.reset.
Thanks,
Nitin
On Fri, May 1, 2020 at 12:28 PM vishnu murali
wrote:
> Hey Guys,
>
> I am trying to move data between one cluster to another cluster
>
>
>
> *Source*
>
> *Destination*
>
> *Zookeeper*
>
> 2181
>
> 2182
>
Hey Guys,
I am trying to move data between one cluster to another cluster
*Source*
*Destination*
*Zookeeper*
2181
2182
*Kafka*
9092
9091
*ConsumerProperties:*
bootstrap.servers=localhost:9092
group.id=test-consumer-group
auto.offset.rest=earliest
*Producer Properties:*
bootstrap.s