Do not add container producers to the general producer cache.

[garyrussell]

When we added support for zombie fencing, a container producer is created for each topic/partitiogroup. Such producers should not be added to the general cache for use by arbitrary KafkaTemplate transactions.

https://stackoverflow.com/questions/53803052/spring-kafka-with-transactions-multiple-threads/53803559#53803559

[kgunnerud]

In our code, we also use a KafkaTemplate within the current listener.
https://github.com/Lg87/kafka-transaction-example/blob/master/src/main/java/test/TestCase.java#L42
In what you mention above, will the KafkaTemplate be a part of the current transaction?

Our code is as following:
KafkaMessageListenerContainer --> Our listener --> KafkaTemplate.send() --> 1 message

Scheduled Job (nothing to do with the listener above):
ScheduledClass --> KafkaTemplate.executeInTransaction() --> send 2 messages to different topics.

[garyrussell]

Yes; it will participate in the contaner transaction; the issue is when the container transaction is completed, the producer is incorrectly put into the cache and will be reused by the stand-alone template, which is wrong.