<?php
namespace App\Worker;
use RdKafka;

ini_set('display_errors', 1);
error_reporting(E_ALL);
require_once dirname(__DIR__, 2) . '/vendor/autoload.php';
$dotenv = \Dotenv\Dotenv::createImmutable(dirname(__DIR__, 2));
$dotenv->load();

$conf = new RdKafka\Conf();
$conf->set('bootstrap.servers', '150.242.73.4:9095');

$producer = new RdKafka\Producer($conf);
/** @var \RdKafka\ProducerTopic $topic */
$topic = $producer->newTopic("test");

if (!defined('RD_KAFKA_PARTITION_UA')) {
	define('RD_KAFKA_PARTITION_UA', -1);
}

$topic->produce(RD_KAFKA_PARTITION_UA, 0, json_encode(["name"=>"Hello from PHP!"]));
$producer->flush(10000);

echo "Message sent to Kafka\n";