MirrorMaker and

[Paul Podolny <pp...@outbrain.com>]

Hi,

Is it possible to enable idempotent producing in MirrorMaker?
By code examples, I've seen this needs to be explicitly enabled via the producer API by sending a 'initTransactions' method: https://github.com/omkreddy/kafka-examples/blob/master/producer/src/main/java/kafka/examples/producer/TransactionalProducerExample.java#L63

My Producer config:
----------------------------------
compression.type=gzip
acks=all
enable.idempotence=true
transactional.id=mm-1-test
client.id=transactional-producer
retries=3
max.in.flight.requests.per.connection=1

When I start MM, I get the following exception indicating I'm trying to produce before sending initTransaction:

Exception:
-----------------------
java.lang.IllegalStateException: Cannot perform a 'send' before completing a call to initTransactions when transactions are enabled.
	at org.apache.kafka.clients.producer.internals.TransactionManager.failIfNotReadyForSend(TransactionManager.java:285)
	at org.apache.kafka.clients.producer.internals.TransactionManager.maybeAddPartitionToTransaction(TransactionManager.java:265)
	at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:899)
	at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:840)
	at kafka.tools.ConsoleProducer$.send(ConsoleProducer.scala:74)
	at kafka.tools.ConsoleProducer$.main(ConsoleProducer.scala:56)
	at kafka.tools.ConsoleProducer.main(ConsoleProducer.scala)

Same applies for console producer.