You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Right now, when a query is terminated, we use the streams reset tool which just resets the committed offsets for the consumer group used by the application id.
However, for KSQL, the consumer group should really be deleted.
Right now, when a query is terminated, we use the streams reset tool which just resets the committed offsets for the consumer group used by the application id.
However, for KSQL, the consumer group should really be deleted.
Now that KIP-222 is available (https://cwiki.apache.org/confluence/display/KAFKA/KIP-222+-+Add+Consumer+Group+operations+to+Admin+API), we can delete the consumer group once terminate is called using the Java AdminClient.
The text was updated successfully, but these errors were encountered: