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
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
Comments
Post a Comment