sender.php

<?php

ini_set('display_errors', 1);
ini_set('display_startup_errors', 1);
error_reporting(E_ALL);

require_once 'Core/Logger.php';

Logger::log('Sender script: New message');

if (empty($_POST['message'])) {

    echo "Error: Sending message can't be empty!\n";

} elseif (empty($_POST['topic'])) {

    echo "Error: Topic for sending can't be empty!\n";

} else {

    json_decode($_POST['message']);
    if (json_last_error() === JSON_ERROR_NONE) {

        require_once 'Core/KafkaProducer.php';

        $config_file = 'config_default.ini';
        $config      = parse_ini_file($config_file, true);

        $producer = new KafkaProducer($config);

        $producer->send($_POST['topic'], $_POST['message']);
        Logger::log('Sender script: Message ' . $_POST['message'] . ' sended to Kafka topic ' . $_POST['topic']);
    } else {

        echo "Error: Incompatible data format!\n";
    }

}