linux下php扩展kafka的实例分享

$kafka = new Kafka("localhost:9092");

$partitions = $kafka->getPartitionsForTopic('testkk');

$in = fopen('php://stdin', 'r');

while (true) {

    echo "\nEnter comma separated messages:\n";

    $messages = explode(',', fgets($in));

    foreach (array_keys($messages) as $k) {

        //$messages[$k] = trim($messages[$k]);

    }

        $bytes=$kafka->produce("testkk", "kkkkkkk");

    printf("\nSuccessfully sent %d messages (%d bytes)\n\n", count($messages), $bytes);

}