subscribe
public function subscribe(array $topics): void {}
Subscribe to one or more topics (regexp also supported).
Any previous subscription will be unassigned and unsubscribed first.
$conf = SimpleKafkaClient\Configuration();
$conf->set('metadata.broker.list', 'kafka:9092');
$consumer = new SimpleKafkaClient\Consumer($conf);
$consumer->subscribe(['test-topic']);