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

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

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

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

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

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

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


Alat panas

Pustaka PHP untuk bekas suntikan kebergantungan
Pustaka PHP untuk bekas suntikan kebergantungan

Koleksi 50 algoritma PHP klasik yang sangat baik
Algoritma PHP klasik, pelajari idea yang sangat baik dan kembangkan pemikiran anda

Pustaka PHP kecil untuk mengoptimumkan imej
Pustaka PHP kecil untuk mengoptimumkan imej
