When the KafkaConsumer operator is used with control input port, and one of the topic, pattern, partition, and startPosition parameters is given, they are ignored. A warning occurs at compile time. This is fine as long as the control port only allows assignment/unassignment of topic partitions to consume.
The warning should be turned into a compile error for future functional enhancements of the control port.
An example for enhancement is committing offsets via control port. In this case, the 4 parameters have a meaning. If given, the operator would subscribe and initially seek. Then the assign via control port would be forbidden. Absence of these parameters would mean, that also assign/unassign is allowed via control port.
As this is a change in behavior, this issue is a candidate for a major release.
ghost
commented
4 years ago
When the KafkaConsumer operator is used with control input port, and one of the topic, pattern, partition, and startPosition parameters is given, they are ignored. A warning occurs at compile time. This is fine as long as the control port only allows assignment/unassignment of topic partitions to consume.
The warning should be turned into a compile error for future functional enhancements of the control port.
An example for enhancement is committing offsets via control port. In this case, the 4 parameters have a meaning. If given, the operator would subscribe and initially seek. Then the assign via control port would be forbidden. Absence of these parameters would mean, that also assign/unassign is allowed via control port.
As this is a change in behavior, this issue is a candidate for a major release.