modify alert sql
This commit is contained in:
parent
b9165de6b2
commit
23b54e1df4
|
@ -163,7 +163,7 @@ if __name__ == "__main__":
|
||||||
seek_offset(consumer)
|
seek_offset(consumer)
|
||||||
commit_offset(consumer)
|
commit_offset(consumer)
|
||||||
consumer.unsubscribe()
|
consumer.unsubscribe()
|
||||||
print("Consumer unsubscribed successfully.");
|
print("Consumer unsubscribed successfully.")
|
||||||
except Exception as err:
|
except Exception as err:
|
||||||
print(f"Failed to stmt consumer. ErrMessage:{err}")
|
print(f"Failed to stmt consumer. ErrMessage:{err}")
|
||||||
finally:
|
finally:
|
||||||
|
|
Loading…
Reference in New Issue