title	date	draft
close	2020-12-27 22:09:37 +0100	false

Description

public function close(): void {}

Close down the Consumer. This call will block until
the consumer has revoked its assignment, calling the rebalance callback
if it is configured, committed offsets to broker, and left the consumer group. The maximum blocking time is roughly limited to session.timeout.ms.

Example

$conf = SimpleKafkaClient\Configuration();
$conf->set('metadata.broker.list', 'kafka:9092');
$consumer = new SimpleKafkaClient\Consumer($conf);
$consumer->close();

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Uh oh!