i start the kafka mirror using the below configuration .\bin\windows\kafka-mirror-maker.bat --consumer.config .\config\consumer.properties --producer.config .\config\producer.properties --whitelist=".*"
*Consumer.properties:* # format: host1:port1,host2:port2 ... bootstrap.servers=localhost:9092 # consumer group id group.id=test-consumer-group *Producer.properties:* # format: host1:port1,host2:port2 ... bootstrap.servers=localhost:9091 # specify the compression codec for all data generated: none, gzip, snappy, lz4, zstd compression.type=none I get this kind of warning statement and it will be still present in that statement of more than 30 minutes.No data will be transfered 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' can anyone clarify why i am getting this and what i am doing wrong? On Thu, Apr 30, 2020 at 12:22 AM vishnu murali <vishnumurali9...@gmail.com> wrote: > Thanks Blake..😊😊 > > More over can we use any connector types for this situation? > > Like source is a topic and sink is also an another topic > > Is this possible... > > On Thu, Apr 30, 2020, 00:19 Blake Miller <blak3mil...@gmail.com> wrote: > >> Hi Vishnu, >> >> Check out MirrorMaker >> https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=27846330 >> >> This can do what you want. Note that the offsets are not copied, nor are >> the message timestamps. >> >> HTH >> >> >> On Wed, Apr 29, 2020 at 6:47 PM vishnu murali <vishnumurali9...@gmail.com >> > >> wrote: >> >> > Hi Guys, >> > >> > I am having two separate Kafka cluster running in two independent >> zookeeper >> > >> > I need to send a set of data from one topic from cluster A to cluster B >> > with the same topic name with all data also.. >> > >> > How can I achieve this >> > >> > Done anyone have any idea ?? >> > >> >
