Rumah

Perpustakaan PHP

Perpustakaan lain

perpustakaan pelanggan php-rdkafka

Perpustakaan lain

Dapatkannya sekarang

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();
}

Penafian

Semua sumber di laman web ini disumbangkan oleh netizen atau dicetak semula oleh tapak muat turun utama. Sila semak integriti perisian itu sendiri! Semua sumber di laman web ini adalah untuk rujukan pembelajaran sahaja. Tolong jangan gunakannya untuk tujuan komersial. Jika tidak, anda akan bertanggungjawab untuk semua akibat! Jika terdapat sebarang pelanggaran, sila hubungi kami untuk memadamkannya. Maklumat hubungan: admin@php.cn

Artikel Berkaitan

## 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,...

Apakah Perpustakaan PHP Paling Mudah untuk Pengesahan Borang?

17 Oct 2024

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

Ralat Permulaan PHP: Mengapa PHP Tidak Dapat Memuatkan Perpustakaan Dinamik Saya?

05 Dec 2024

Amaran PHP: Permulaan PHP: Tidak Dapat Memuat Perpustakaan DinamikMesej ralat ini menunjukkan isu dengan memuatkan perpustakaan dinamik tertentu apabila PHP...

See all articles