These are chat archives for arnaud-lb/php-rdkafka

15th
Jul 2016
axiao
@joostshao
Jul 15 2016 04:05
is RD_KAFKA_PARTITION_UA just used for producer ?
how to consumer kafka topic from all partitions?
axiao
@joostshao
Jul 15 2016 05:03
%3|1468558926.735|FAIL|rdkafka#consumer-1| 172.16.0.148:9092/0: Receive failed: Disconnected
%3|1468558926.735|ERROR|rdkafka#consumer-1| 172.16.0.148:9092/0: Receive failed: Disconnected
%3|1468558926.735|ERROR|rdkafka#consumer-1| 1/1 brokers are down
%3|1468558926.847|FAIL|rdkafka#consumer-1| 172.16.0.148:9092/0: Receive failed: Disconnected
%3|1468558926.848|ERROR|rdkafka#consumer-1| 172.16.0.148:9092/0: Receive failed: Disconnected
%3|1468558926.848|ERROR|rdkafka#consumer-1| 1/1 brokers are down
%3|1468558927.441|FAIL|rdkafka#consumer-1| 172.16.0.148:9092/0: Receive failed: Disconnected
%3|1468558927.441|ERROR|rdkafka#consumer-1| 172.16.0.148:9092/0: Receive failed: Disconnected
%3|1468558927.442|ERROR|rdkafka#consumer-1| 1/1 brokers are down
when i use $conf->setRebalanceCb
ahuigo
@ahuigo
Jul 15 2016 05:19
@joostshao
  1. RD_KAFKA_PARTITION_UA is just used for producer, because it lets librdkafka choose the partition.
  2. how to consumer kafka topic from all partitions?
    You could get these partitions via Metadata:
         $topic = $consumer->newTopic("topic name", $topicConf);
         $metaData = $consumer->getMetadata(false, $topic, 1000);
         $partitions = $metaData->getTopics()->current()->getPartitions();
axiao
@joostshao
Jul 15 2016 05:36
@hilojack thank you, i am trying
i am confusing about the pramaters
When TRUE, request info about all topics in cluster. Else, only request info about locally known topics.
what for locally known topics meaning ?
axiao
@joostshao
Jul 15 2016 07:47
RdKafka\Metadata\Collection {#7}
RdKafka\Metadata {#6}
the weekend