kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kidong Lee <mykid...@gmail.com>
Subject Re: Mirror Maker tool is not running
Date Sun, 05 May 2019 11:09:43 GMT
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 <iashok7@outlook.com>님이 작성:

>
>
> Sent from Outlook
>
> On 30-Apr-2019 3:37 PM, ASHOK MACHERLA <iAshok7@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
>
>
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message