ดาวน์โหลด kafka php - ดาวน์โหลด kafka php ซอร์สโค้ด

kafka php

หมวดหมู่อื่นๆ

V0.2.0.8

ดาวน์โหลด

คาฟคา-php

中文档

Kafka-php เป็นไคลเอนต์ PHP kafka ล้วนๆ ที่ปัจจุบันรองรับ Kafka เวอร์ชันมากกว่า 0.8.x โปรเจ็กต์ v0.2.x และ v0.1.x นี้เข้ากันไม่ได้หากใช้ v0.1.x ดั้งเดิม คุณสามารถอ้างอิงถึง document Kafka PHP v0.1.x Document แต่แนะนำให้เปลี่ยนเป็น v0.2.x v0.2.x ใช้ PHP แบบอะซิงโครนัสและการโต้ตอบของโบรกเกอร์ kafka มีเสถียรภาพมากกว่า v0.1.x มีประสิทธิภาพ เนื่องจากการใช้ภาษา PHP ดังนั้นอย่าคอมไพล์ส่วนขยายใด ๆ สามารถใช้เพื่อลดต้นทุนการเข้าถึงและบำรุงรักษา

ความต้องการ

เวอร์ชัน PHP ขั้นต่ำ: 7.1
Kafka เวอร์ชันมากกว่า 0.8
โมดูลผู้บริโภคต้องการเวอร์ชันโบรกเกอร์ kafka ที่มากกว่า 0.9.0

การติดตั้ง

เพิ่มไดเร็กทอรี lib ลงใน PHP include_path และใช้ตัวโหลดอัตโนมัติเหมือนกับที่อยู่ในไดเร็กทอรีตัวอย่าง (โค้ดเป็นไปตามแบบแผน PEAR/Zend one-class-per-file)

การติดตั้งนักแต่งเพลง

เพียงเพิ่มการขึ้นต่อกัน nmred/kafka-php ให้กับโปรเจ็กต์ของคุณ หากคุณใช้ Composer เพื่อจัดการการขึ้นต่อกันของโปรเจ็กต์ของคุณ

$ composer require nmred/kafka-php

นี่คือตัวอย่างขั้นต่ำของไฟล์ composer.json :

 {
	"require": {
		"nmred/kafka-php": "0.2.*"
	}
}

การกำหนดค่า

คุณสมบัติการกำหนดค่าได้รับการบันทึกไว้ในการกำหนดค่า

ผู้ผลิต

โหมดอะซิงโครนัส

 <?php
require ' ../vendor/autoload.php ' ;
date_default_timezone_set ( ' PRC ' );
use Monolog  Logger ;
use Monolog  Handler  StdoutHandler ;
// Create the logger
$ logger = new Logger ( ' my_logger ' );
// Now add some handlers
$ logger -> pushHandler ( new StdoutHandler ());

$ config =  Kafka ProducerConfig:: getInstance ();
$ config -> setMetadataRefreshIntervalMs ( 10000 );
$ config -> setMetadataBrokerList ( ' 10.13.4.159:9192 ' );
$ config -> setBrokerVersion ( ' 1.0.0 ' );
$ config -> setRequiredAck ( 1 );
$ config -> setIsAsyn ( false );
$ config -> setProduceInterval ( 500 );
$ producer = new  Kafka  Producer (
    function () {
        return [
            [
                ' topic ' => ' test ' ,
                ' value ' => ' test....message. ' ,
                ' key ' => ' testkey ' ,
            ],
        ];
    }
);
$ producer -> setLogger ( $ logger );
$ producer -> success ( function ( $ result ) {
	var_dump ( $ result );
});
$ producer -> error ( function ( $ errorCode ) {
		var_dump ( $ errorCode );
});
$ producer -> send ( true );

โหมดซิงโครนัส

 <?php
require ' ../vendor/autoload.php ' ;
date_default_timezone_set ( ' PRC ' );
use Monolog  Logger ;
use Monolog  Handler  StdoutHandler ;
// Create the logger
$ logger = new Logger ( ' my_logger ' );
// Now add some handlers
$ logger -> pushHandler ( new StdoutHandler ());

$ config =  Kafka ProducerConfig:: getInstance ();
$ config -> setMetadataRefreshIntervalMs ( 10000 );
$ config -> setMetadataBrokerList ( ' 127.0.0.1:9192 ' );
$ config -> setBrokerVersion ( ' 1.0.0 ' );
$ config -> setRequiredAck ( 1 );
$ config -> setIsAsyn ( false );
$ config -> setProduceInterval ( 500 );
$ producer = new  Kafka  Producer ();
$ producer -> setLogger ( $ logger );

for ( $ i = 0 ; $ i < 100 ; $ i ++) {
    $ producer -> send ([
        [
            ' topic ' => ' test1 ' ,
            ' value ' => ' test1....message. ' ,
            ' key ' => '' ,
        ],
    ]);
}

ผู้บริโภค

 <?php
require ' ../vendor/autoload.php ' ;
date_default_timezone_set ( ' PRC ' );
use Monolog  Logger ;
use Monolog  Handler  StdoutHandler ;
// Create the logger
$ logger = new Logger ( ' my_logger ' );
// Now add some handlers
$ logger -> pushHandler ( new StdoutHandler ());

$ config =  Kafka ConsumerConfig:: getInstance ();
$ config -> setMetadataRefreshIntervalMs ( 10000 );
$ config -> setMetadataBrokerList ( ' 10.13.4.159:9192 ' );
$ config -> setGroupId ( ' test ' );
$ config -> setBrokerVersion ( ' 1.0.0 ' );
$ config -> setTopics ([ ' test ' ]);
// $ config - > setOffsetReset ( 'earliest' );
$ consumer = new  Kafka  Consumer ();
$ consumer -> setLogger ( $ logger );
$ consumer -> start ( function ( $ topic , $ part , $ message ) {
	var_dump ( $ message );
});