Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
1.14.3
-
None
-
None
Description
Topic partition map is initialized when the first message is processed rather then constructor
Code at constructor
this.topicPartitionsMap = new HashMap<>();
Code at invoke method
int[] partitions = topicPartitionsMap.get(targetTopic); if (null == partitions) { partitions = getPartitionsByTopic(targetTopic, transaction.producer); topicPartitionsMap.put(targetTopic, partitions); }
Can this behavior be changed?