Hi,
I am using uReplicator with kafka client version 0.9.0.1 in production and faced "Memory records is not writable in MirrorMaker".
I understood that this issue is resolved by providing the solution for issue KAFKA-3147 and released a new version of kafka client jar "0.9.0-kafka-2.0.2".
I have updated uReplicator with kafka client jar version "0.9.0-kafka-2.0.2" and still i am facing the issue.
Could you please help me in resolving this issue.
Exception Details:
java.lang.IllegalStateException: Memory records is not writable
org.apache.kafka.common.record.MemoryRecords.append(MemoryRecords.java:93)
org.apache.kafka.clients.producer.internals.RecordBatch.tryAppend(RecordBatch.java:69)
org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:168)
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:435)
kafka.mirrormaker.MirrorMakerWorker$MirrorMakerProducer.send(MirrorMakerWorker.scala:357)
kafka.mirrormaker.MirrorMakerWorker$MirrorMakerThread.run(MirrorMakerWorker.scala:298)
Hi, I am using uReplicator with kafka client version 0.9.0.1 in production and faced "Memory records is not writable in MirrorMaker".
I understood that this issue is resolved by providing the solution for issue KAFKA-3147 and released a new version of kafka client jar "0.9.0-kafka-2.0.2".
I have updated uReplicator with kafka client jar version "0.9.0-kafka-2.0.2" and still i am facing the issue.
Could you please help me in resolving this issue.
Exception Details:
java.lang.IllegalStateException: Memory records is not writable org.apache.kafka.common.record.MemoryRecords.append(MemoryRecords.java:93) org.apache.kafka.clients.producer.internals.RecordBatch.tryAppend(RecordBatch.java:69) org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:168) org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:435) kafka.mirrormaker.MirrorMakerWorker$MirrorMakerProducer.send(MirrorMakerWorker.scala:357) kafka.mirrormaker.MirrorMakerWorker$MirrorMakerThread.run(MirrorMakerWorker.scala:298)