Skip to content

Commit

Permalink
tests/kafka_cli_consumer: using graceful shutdown when stopping consumer
Browse files Browse the repository at this point in the history
When consumer is being stopped it may send `LeaveGroup` request to the
broker. Using clean shutdown (SIGTERM) to give the consumer process
oportunity to finish gracefully.

Signed-off-by: Michal Maslanka <michal@vectorized.io>
  • Loading branch information
mmaslankaprv committed May 16, 2022
1 parent df344ef commit b6f7030
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion tests/rptest/services/kafka_cli_consumer.py
Original file line number Diff line number Diff line change
Expand Up @@ -93,4 +93,4 @@ def wait_for_messages(self, messages, timeout=30):

def stop_node(self, node):
self._stopping.set()
node.account.kill_process("java", clean_shutdown=False)
node.account.kill_process("java", clean_shutdown=True)

0 comments on commit b6f7030

Please sign in to comment.