KafkaConsumer: Deprecate support of control port in consistent region

IBMStreams / streamsx.kafka

Repository for integration with Apache Kafka

https://ibmstreams.github.io/streamsx.kafka/

Apache License 2.0

13 stars 9 forks source link

KafkaConsumer: Deprecate support of control port in consistent region #189

Closed ghost closed 4 years ago

ghost commented 5 years ago

The control stream is always outside of the consistent region. When the operator is reset to a prior state, changes (subscription, partition assignment) done via control port may get lost.