<?php

/**
 * Example (PHP 7.0-compatible): publish a message to a topic.
 *
 * Run: php produce.php
 */

require_once __DIR__ . '/../autoload.php';

$config   = new KafkaConfig('127.0.0.1:9092');
$producer = new Producer($config);

// PHP 7.0 has no named arguments — pass key/headers positionally.
$producer->produce(
    'orders',
    array('order_id' => 1001, 'amount' => 49.99, 'email' => 'user@example.com'),
    'order-1001',                       // $key
    array('source' => 'checkout')       // $headers
);

echo "Message published to 'orders'.\n";