When the consumer group has only one consumer, the reset implementation can be simplified.
Multiple operator checkpoints need not be merged into one group checkpoint via the group MX bean.
How to detect, that only one consumer needs to be reset in a consumer group:
ghost
commented
4 years ago
When the consumer group has only one consumer, the reset implementation can be simplified. Multiple operator checkpoints need not be merged into one group checkpoint via the group MX bean.
How to detect, that only one consumer needs to be reset in a consumer group:
Every consumer operator is registers in the group MX bean in setup with its operator name when the connection to the JCP is created. https://github.com/IBMStreams/streamsx.kafka/blob/bd2d899e554fcef4260565c04973cbd4aada1769/com.ibm.streamsx.kafka/impl/java/src/com/ibm/streamsx/kafka/clients/consumer/CrKafkaConsumerGroupClient.java#L232 The registered operators are part of every operator's checkpoint. When the checkpoint contains only the own operator name, the optimization applies.