-
Stop the consumer;
-
Execute SQL
SELECT rollback_to($height);
(functionrollback_to
provided via the migrations); -
Invalidate cache using
invalidate
binary or through theadmin
service -/admin/cache/invalidate?mode=all_data
endpoint; -
Start the consumer.