Ini adalah pelanggan yang boleh menghantar dan menerima mesej Di bawah saya akan menunjukkan operasi penghantaran dan penerimaan Rakan yang memerlukannya boleh memuat turunnya dan mencubanya.

Hantar mesej

<?phptry {
    $rcf = new RdKafka\Conf();
    $rcf->set('group.id', 'test');
    $cf = new RdKafka\TopicConf();
    $cf->set('offset.store.method', 'broker');
    $cf->set('auto.offset.reset', 'smallest');
    $rk = new RdKafka\Producer($rcf);
    $rk->setLogLevel(LOG_DEBUG);
    $rk->addBrokers("127.0.0.1");
    $topic = $rk->newTopic("test", $cf);
    for($i = 0; $i < 1000; $i++) {
        $topic->produce(0,0,'test' . $i);//沒有setMessge接口了,使用produce  參考：https://libraries.io/github/mentionapp/php-rdkafka
    } 
} catch (Exception $e) {
    echo $e->getMessage();

Terima mesej

<?phptry {
    $rcf = new RdKafka\Conf();
    $rcf->set('group.id', 'test');
    $cf = new RdKafka\TopicConf();/*
    $cf->set('offset.store.method', 'file');
*/
    $cf->set('auto.offset.reset', 'smallest');
    $cf->set('auto.commit.enable', true);
    $rk = new RdKafka\Consumer($rcf);
    $rk->setLogLevel(LOG_DEBUG);
    $rk->addBrokers("127.0.0.1");
    $topic = $rk->newTopic("test", $cf);    //$topic->consumeStart(0, RD_KAFKA_OFFSET_BEGINNING);
    while (true) {
        $topic->consumeStart(0, RD_KAFKA_OFFSET_STORED);
        $msg = $topic->consume(0, 1000);
        var_dump($msg);        if ($msg->err) {            echo $msg->errstr(), "\n";            break;
        } else {            echo $msg->payload, "\n";
        }
        $topic->consumeStop(0);
        sleep(1);
    }
} catch (Exception $e) {    echo $e->getMessage();
}

Artikel Berkaitan

JavaScript dan perpustakaan PHP yang digunakan oleh WordPress

17 Feb 2025

WordPress sangat bergantung pada JavaScript pihak ketiga dan perpustakaan PHP, di antaranya jQuery adalah perpustakaan JavaScript yang paling banyak digunakan, dan perpustakaan PHP terutamanya terdiri daripada satu fail kelas. Perpustakaan JavaScript lain yang digunakan termasuk jQuery Masonry, Jquery Hotkeys, Jquery Cadangan, Borang JQuery, Warna JQuery, JQuery Migrate, Jquery Jadual, JQuery UI, Backbone, Colorpicker, Hoverintent, S

## Apakah Perpustakaan Pelanggan Python SOAP Terbaik untuk Digunakan pada tahun 2023?

25 Oct 2024

Perpustakaan Pelanggan Python SOAP: Dokumentasi dan PilihanMelayari dunia perpustakaan klien SOAP Python boleh menjadi menakutkan bagi pemula. Sementara...

Bagaimana untuk Membetulkan Ralat 'Versi Perpustakaan Pelanggan MySQL yang Salah' dengan Permata MySQL2?

25 Dec 2024

Permata MySQL2: Menyelesaikan Masalah Ralat Penyusunan dengan Perpustakaan Pelanggan MySQLRalat "Versi perpustakaan klien MySQL salah" berlaku apabila...

**Perpustakaan Pelanggan Python SOAP Mana Yang Sesuai untuk Anda? Menavigasi Pilihan Pelbagai dan Dokumentasinya.**

25 Oct 2024

Perpustakaan Pelanggan SOAP Python Pelbagai: Menavigasi Labyrinth DokumentasiUntuk pembangun Python pemula yang meneroka SOAP dan perpustakaan kliennya,...

Versi Perpustakaan Pelanggan MySQL Tidak Padan dalam Rails: Cara Membetulkan 'Versi perpustakaan klien MySQL yang salah!' Ralat?

01 Dec 2024

Ralat dalam Aplikasi Rails: Versi Perpustakaan Pelanggan MySQL MismatchApabila cuba mewujudkan sambungan pangkalan data dengan aplikasi Rails,...

Memudahkan Interaksi API REST: Cara Menggunakan Perpustakaan Ogillot/PHP-Restclient

18 Apr 2025

Apabila membangunkan projek yang memerlukan interaksi yang kerap dengan Restapi luaran, saya menghadapi masalah yang sukar: setiap permintaan memerlukan secara manual membina permintaan HTTP, mengendalikan pengesahan, maklumat header, parameter, dan lain-lain, yang besar dan rawan kesilapan. Selepas mencuba pelbagai kaedah, saya dapati perpustakaan Ogillot/PHP-Restclient, yang sangat memudahkan kerja saya dan meningkatkan kecekapan pembangunan.

See all articles