Tansformation Plugin - multiple instances

Kafka Connect
1

I am using custom Transformer plugin to do some manipulation.
class Transformer<R extends ConnectRecord<R>> implements Transformation<R>

I have only 1 kafka connect , and maxTask is also 1.

I added a constructor to this class where I print a message.
I saw that the message printed multiple time - means that object was created multiple times as well.

My question why this happens if I have only 1 task?
I also want to use constructor to init some utility class only once…

2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.