RdKafka\KafkaConsumer クラス

(PECL rdkafka >= 1.0.0, librdkafka >= 0.9)

はじめに

これは自動パーティション割り当て/取消のためのサポートを持つ高レベルのKafkaConsumerです (Kafka >= 0.9 が必要)。

RdKafka\KafkaConsumer {

/* メソッド */

public void assign ([ array $topic_partitions = NULL ] )

public void commit ([ mixed $message_or_offsets = NULL ] )

public boid commitAsync ([ string $message_or_offsets = NULL ] )

public RdKafka\Message consume ( string $timeout_ms )

public array getAssignment ( void )

public RdKafka\Metadata getMetadata ( bool $all_topics , RdKafka\KafkaConsumerTopic $only_topic = NULL , int $timeout_ms )

public array getSubscription ( void )

public void subscribe ( array $topics )

public ReturnType unsubscribe ( void )

}