setFormatter(new ConsoleFormatter()); $logger = new Logger('publisher', [$handler], [new PsrLogMessageProcessor()]); $producer = new Producer( 'tcp://localhost:4150', clientConfig: new ClientConfig( deflate: false, heartbeatInterval: 5000, snappy: true, ), logger: $logger, ); yield $producer->connect(); while (true) { yield $producer->publish(topic: 'local', body: array_fill(0, 200, 'Message body!')); } });