perpustakaan pelanggan php-rdkafka

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

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

25Oct2024

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

JavaScript dan perpustakaan PHP yang digunakan oleh WordPress

17Feb2025

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

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

25Dec2024

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.**

25Oct2024

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?

01Dec2024

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

Apakah Perpustakaan PHP Paling Mudah untuk Pengesahan Borang?

17Oct2024

Perpustakaan Pengesahan Borang Termudah untuk PHPDalam mencari perpustakaan PHP mudah yang memudahkan tugas pengesahan borang? Mari terokai pilihan anda:Contoh Perpustakaan TersuaiPengguna mencadangkan kelas PHP tersuai yang menggabungkan corak regex yang dipratentukan

See all articles