search

practo / tipoca-stream

Near real time cloud native data pipeline in AWS (CDC+Sink). Hosts code for RedshiftSink. RDS to RedshiftSink Pipeline with masking and reloading support.
https://towardsdatascience.com/open-sourcing-tipoca-stream-f261cdcc3a13
Apache License 2.0
47 stars 5 forks source link

Delete dead consumer groups #234

Closed alok87 closed 3 years ago

alok87 commented 3 years ago

The old consumers which were deleted needs to be cleaned if they exist. This will prevent false kafka alerts for them

Fixes #157

Also renames the watcher to client as the use broadens