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
>
> *Kafka*
>
> 9092
>
> 9091
>
>
>
> *ConsumerProperties:*
>
> bootstrap.servers=localhost:9092
> group.id=test-consumer-group
> auto.offset.rest=earliest
>
>
>
> *Producer Properties:*
> bootstrap.servers=localhost:9091
> compression.type=none
>
>
> i am having topic in 9092 as actor which is from MySQL Sakila Schema actor
> table
>
>
> In the 9091 i don't have any topic ,so i try to migrate data from 9092
> ->9091 it is showing like
>
>
> D:\kafka>.\bin\windows\kafka-mirror-maker.bat --consumer.config
> .\config\consumer.properties --producer.config .\config\producer.properties
> --whitelist actor
>
>
> WARNING: The default partition assignment strategy of the mirror maker will
> change from 'range' to 'roundrobin' in an upcoming release (so that better
> load balancing can be achieved). If you prefer to make this switch in
> advance of that release add the following to the corresponding config:
>
> 'partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor'
>
>
> [2020-05-01 12:04:55,024] WARN The configuration 'auto.offset.rest' was
> supplied but isn't a known config.
> (org.apache.kafka.clients.consumer.ConsumerConfig)
>
>
> *it's stucked in that place itself no more operations is performed*
>
>
> and the topic is not copied into 9091
>
>
> i dont know why
>
>
> can anyone able to identify and explain me a way to do it please?
>
