Hi, I have written a tool like mirror maker: https://github.com/mykidong/kafka-spiegel/blob/master/README.md
You can try this. Cheers, Kidong Lee 2019년 5월 4일 (토) 오후 8:38, ASHOK MACHERLA <iash...@outlook.com>님이 작성: > > > Sent from Outlook > > On 30-Apr-2019 3:37 PM, ASHOK MACHERLA <iash...@outlook.com> wrote: > > Dear Team > > > > Please help us , our mirror maker tool is not running properly > > > > > > Please look into this belowmirror maker log file exceptions > > > > > > ****************************************************************** > > [2019-03-11 18:34:31,906] ERROR Error when sending message to topic > audit-logs with key: null, value: 304134 bytes with error: > (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) > > org.apache.kafka.common.errors.RecordTooLargeException: The request > included a message larger than the max message size the server will accept. > > [2019-03-11 18:34:31,909] FATAL [mirrormaker-thread-15] Mirror maker > thread failure due to (kafka.tools.MirrorMaker$MirrorMakerThread) > > java.lang.IllegalStateException: Cannot send after the producer is closed. > > at > org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:185) > > at > org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:474) > > at > org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:436) > > at > kafka.tools.MirrorMaker$MirrorMakerProducer.send(MirrorMaker.scala:657) > > at > kafka.tools.MirrorMaker$MirrorMakerThread$$anonfun$run$6.apply(MirrorMaker.scala:434) > > at > kafka.tools.MirrorMaker$MirrorMakerThread$$anonfun$run$6.apply(MirrorMaker.scala:434) > > at scala.collection.Iterator$class.foreach(Iterator.scala:893) > > at scala.collection.AbstractIterator.foreach(Iterator.scala:1336) > > at > scala.collection.IterableLike$class.foreach(IterableLike.scala:72) > > at scala.collection.AbstractIterable.foreach(Iterable.scala:54) > > at > kafka.tools.MirrorMaker$MirrorMakerThread.run(MirrorMaker.scala:434) > > > > Sent from Mail<https://go.microsoft.com/fwlink/?LinkId=550986> for > Windows 10 > > > >
