php-pecl-rdkafka: 1.0.0 (php 5) and 2.0.0 (php 7)

1 files changed, 481 insertions, 151 deletions

diff --git a/REFLECTION b/REFLECTION
index de6ccf5..9333932 100644
--- a/REFLECTION
+++ b/REFLECTION
@@ -1,13 +1,14 @@
-Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
+Extension [ <persistent> extension #64 rdkafka version 1.0.0 ] {
 
-  - Constants [48] {
+  - Constants [88] {
     Constant [ integer RD_KAFKA_CONSUMER ] { 1 }
     Constant [ integer RD_KAFKA_OFFSET_BEGINNING ] { -2 }
     Constant [ integer RD_KAFKA_OFFSET_END ] { -1 }
     Constant [ integer RD_KAFKA_OFFSET_STORED ] { -1000 }
     Constant [ integer RD_KAFKA_PARTITION_UA ] { -1 }
     Constant [ integer RD_KAFKA_PRODUCER ] { 0 }
-    Constant [ integer RD_KAFKA_VERSION ] { 590079 }
+    Constant [ integer RD_KAFKA_VERSION ] { 590335 }
+    Constant [ integer RD_KAFKA_BUILD_VERSION ] { 590335 }
     Constant [ integer RD_KAFKA_RESP_ERR__BEGIN ] { -200 }
     Constant [ integer RD_KAFKA_RESP_ERR__BAD_MSG ] { -199 }
     Constant [ integer RD_KAFKA_RESP_ERR__BAD_COMPRESSION ] { -198 }
@@ -26,6 +27,22 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
     Constant [ integer RD_KAFKA_RESP_ERR__TIMED_OUT ] { -185 }
     Constant [ integer RD_KAFKA_RESP_ERR__QUEUE_FULL ] { -184 }
     Constant [ integer RD_KAFKA_RESP_ERR__ISR_INSUFF ] { -183 }
+    Constant [ integer RD_KAFKA_RESP_ERR__NODE_UPDATE ] { -182 }
+    Constant [ integer RD_KAFKA_RESP_ERR__SSL ] { -181 }
+    Constant [ integer RD_KAFKA_RESP_ERR__WAIT_COORD ] { -180 }
+    Constant [ integer RD_KAFKA_RESP_ERR__UNKNOWN_GROUP ] { -179 }
+    Constant [ integer RD_KAFKA_RESP_ERR__IN_PROGRESS ] { -178 }
+    Constant [ integer RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS ] { -177 }
+    Constant [ integer RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION ] { -176 }
+    Constant [ integer RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS ] { -175 }
+    Constant [ integer RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS ] { -174 }
+    Constant [ integer RD_KAFKA_RESP_ERR__CONFLICT ] { -173 }
+    Constant [ integer RD_KAFKA_RESP_ERR__STATE ] { -172 }
+    Constant [ integer RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL ] { -171 }
+    Constant [ integer RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED ] { -170 }
+    Constant [ integer RD_KAFKA_RESP_ERR__AUTHENTICATION ] { -169 }
+    Constant [ integer RD_KAFKA_RESP_ERR__NO_OFFSET ] { -168 }
+    Constant [ integer RD_KAFKA_RESP_ERR__OUTDATED ] { -167 }
     Constant [ integer RD_KAFKA_RESP_ERR__END ] { -100 }
     Constant [ integer RD_KAFKA_RESP_ERR_UNKNOWN ] { -1 }
     Constant [ integer RD_KAFKA_RESP_ERR_NO_ERROR ] { 0 }
@@ -41,6 +58,29 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
     Constant [ integer RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE ] { 10 }
     Constant [ integer RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH ] { 11 }
     Constant [ integer RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE ] { 12 }
+    Constant [ integer RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION ] { 13 }
+    Constant [ integer RD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESS ] { 14 }
+    Constant [ integer RD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLE ] { 15 }
+    Constant [ integer RD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUP ] { 16 }
+    Constant [ integer RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION ] { 17 }
+    Constant [ integer RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE ] { 18 }
+    Constant [ integer RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS ] { 19 }
+    Constant [ integer RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND ] { 20 }
+    Constant [ integer RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS ] { 21 }
+    Constant [ integer RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION ] { 22 }
+    Constant [ integer RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL ] { 23 }
+    Constant [ integer RD_KAFKA_RESP_ERR_INVALID_GROUP_ID ] { 24 }
+    Constant [ integer RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID ] { 25 }
+    Constant [ integer RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT ] { 26 }
+    Constant [ integer RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS ] { 27 }
+    Constant [ integer RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE ] { 28 }
+    Constant [ integer RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED ] { 29 }
+    Constant [ integer RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED ] { 30 }
+    Constant [ integer RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED ] { 31 }
+    Constant [ integer RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP ] { 32 }
+    Constant [ integer RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM ] { 33 }
+    Constant [ integer RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE ] { 34 }
+    Constant [ integer RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION ] { 35 }
     Constant [ integer RD_KAFKA_CONF_UNKNOWN ] { -2 }
     Constant [ integer RD_KAFKA_CONF_INVALID ] { -1 }
     Constant [ integer RD_KAFKA_CONF_OK ] { 0 }
@@ -52,6 +92,11 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
   }
 
   - Functions {
+    Function [ <internal:rdkafka> function rd_kafka_get_err_descs ] {
+
+      - Parameters [0] {
+      }
+    }
     Function [ <internal:rdkafka> function rd_kafka_err2str ] {
 
       - Parameters [1] {
@@ -66,13 +111,13 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
     }
     Function [ <internal:rdkafka> function rd_kafka_errno ] {
 
-      - Parameters [1] {
-        Parameter #0 [ <optional> $errnox ]
+      - Parameters [0] {
       }
     }
     Function [ <internal:rdkafka> function rd_kafka_offset_tail ] {
 
-      - Parameters [0] {
+      - Parameters [1] {
+        Parameter #0 [ <required> $cnt ]
       }
     }
     Function [ <internal:rdkafka> function rd_kafka_thread_cnt ] {
@@ -82,7 +127,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
     }
   }
 
-  - Classes [16] {
+  - Classes [19] {
     Class [ <internal:rdkafka> abstract class RdKafka ] {
 
       - Constants [0] {
@@ -94,10 +139,12 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Static methods [0] {
       }
 
-      - Properties [0] {
+      - Properties [2] {
+        Property [ <default> private $error_cb ]
+        Property [ <default> private $dr_cb ]
       }
 
-      - Methods [8] {
+      - Methods [11] {
         Method [ <internal:rdkafka> public method addBrokers ] {
 
           - Parameters [1] {
@@ -105,7 +152,22 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
           }
         }
 
-        Method [ <internal:rdkafka> public method metadata ] {
+        Method [ <internal:rdkafka> public method getMetadata ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $all_topics ]
+            Parameter #1 [ <optional> $only_topic ]
+            Parameter #2 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getOutQLen ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka> public method metadata ] {
 
           - Parameters [3] {
             Parameter #0 [ <required> $all_topics ]
@@ -135,7 +197,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
           }
         }
 
-        Method [ <internal:rdkafka> public method outqLen ] {
+        Method [ <internal, deprecated:rdkafka> public method outqLen ] {
 
           - Parameters [0] {
           }
@@ -154,6 +216,12 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
             Parameter #0 [ <required> $logger ]
           }
         }
+
+        Method [ <internal:rdkafka, dtor> public method __destruct ] {
+
+          - Parameters [0] {
+          }
+        }
       }
     }
 
@@ -171,12 +239,11 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Properties [0] {
       }
 
-      - Methods [9] {
+      - Methods [12] {
         Method [ <internal:rdkafka, ctor> public method __construct ] {
 
-          - Parameters [2] {
+          - Parameters [1] {
             Parameter #0 [ <optional> $conf ]
-            Parameter #1 [ <optional> &$errstr ]
           }
         }
 
@@ -187,7 +254,22 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka> public method metadata ] {
+        Method [ <internal:rdkafka, inherits RdKafka> public method getMetadata ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $all_topics ]
+            Parameter #1 [ <optional> $only_topic ]
+            Parameter #2 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method getOutQLen ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method metadata ] {
 
           - Parameters [3] {
             Parameter #0 [ <required> $all_topics ]
@@ -217,7 +299,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka> public method outqLen ] {
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method outqLen ] {
 
           - Parameters [0] {
           }
@@ -236,6 +318,12 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
             Parameter #0 [ <required> $logger ]
           }
         }
+
+        Method [ <internal:rdkafka, inherits RdKafka, dtor> public method __destruct ] {
+
+          - Parameters [0] {
+          }
+        }
       }
     }
 
@@ -253,12 +341,11 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Properties [0] {
       }
 
-      - Methods [9] {
+      - Methods [12] {
         Method [ <internal:rdkafka, ctor> public method __construct ] {
 
-          - Parameters [2] {
+          - Parameters [1] {
             Parameter #0 [ <optional> $conf ]
-            Parameter #1 [ <optional> &$errstr ]
           }
         }
 
@@ -269,7 +356,22 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka> public method metadata ] {
+        Method [ <internal:rdkafka, inherits RdKafka> public method getMetadata ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $all_topics ]
+            Parameter #1 [ <optional> $only_topic ]
+            Parameter #2 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method getOutQLen ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method metadata ] {
 
           - Parameters [3] {
             Parameter #0 [ <required> $all_topics ]
@@ -299,7 +401,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka> public method outqLen ] {
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method outqLen ] {
 
           - Parameters [0] {
           }
@@ -318,6 +420,69 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
             Parameter #0 [ <required> $logger ]
           }
         }
+
+        Method [ <internal:rdkafka, inherits RdKafka, dtor> public method __destruct ] {
+
+          - Parameters [0] {
+          }
+        }
+      }
+    }
+
+    Class [ <internal:rdkafka> class RdKafka\Exception extends Exception ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [4] {
+        Property [ <default> protected $message ]
+        Property [ <default> protected $code ]
+        Property [ <default> protected $file ]
+        Property [ <default> protected $line ]
+      }
+
+      - Methods [10] {
+        Method [ <internal:Core, inherits Exception, ctor> public method __construct ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <optional> $message ]
+            Parameter #1 [ <optional> $code ]
+            Parameter #2 [ <optional> $previous ]
+          }
+        }
+
+        Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+        }
+
+        Method [ <internal:Core, inherits Exception> final public method getMessage ] {
+        }
+
+        Method [ <internal:Core, inherits Exception> final public method getCode ] {
+        }
+
+        Method [ <internal:Core, inherits Exception> final public method getFile ] {
+        }
+
+        Method [ <internal:Core, inherits Exception> final public method getLine ] {
+        }
+
+        Method [ <internal:Core, inherits Exception> final public method getTrace ] {
+        }
+
+        Method [ <internal:Core, inherits Exception> final public method getPrevious ] {
+        }
+
+        Method [ <internal:Core, inherits Exception> final public method getTraceAsString ] {
+        }
+
+        Method [ <internal:Core, inherits Exception> public method __toString ] {
+        }
       }
     }
 
@@ -335,7 +500,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Properties [0] {
       }
 
-      - Methods [4] {
+      - Methods [7] {
         Method [ <internal:rdkafka, ctor> public method __construct ] {
 
           - Parameters [0] {
@@ -350,10 +515,16 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
 
         Method [ <internal:rdkafka> public method set ] {
 
-          - Parameters [3] {
+          - Parameters [2] {
             Parameter #0 [ <required> $name ]
             Parameter #1 [ <required> $value ]
-            Parameter #2 [ <required> $errstr ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setDefaultTopicConf ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $topic_conf ]
           }
         }
 
@@ -363,6 +534,20 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
             Parameter #0 [ <required> $callback ]
           }
         }
+
+        Method [ <internal:rdkafka> public method setDrMsgCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $callback ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method setRebalanceCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $callback ]
+          }
+        }
       }
     }
 
@@ -408,7 +593,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       }
     }
 
-    Class [ <internal:rdkafka> abstract class RdKafka\Topic ] {
+    Class [ <internal:rdkafka> class RdKafka\KafkaConsumer ] {
 
       - Constants [0] {
       }
@@ -419,80 +604,120 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Static methods [0] {
       }
 
-      - Properties [0] {
+      - Properties [3] {
+        Property [ <default> private $error_cb ]
+        Property [ <default> private $rebalance_cb ]
+        Property [ <default> private $dr_msg_cb ]
       }
 
-      - Methods [1] {
-        Method [ <internal:rdkafka> public method getName ] {
+      - Methods [12] {
+        Method [ <internal:rdkafka, ctor> public method __construct ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $conf ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method assign ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <optional> $topic_partitions ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getAssignment ] {
 
           - Parameters [0] {
           }
         }
-      }
-    }
 
-    Class [ <internal:rdkafka> class RdKafka\ConsumerTopic extends RdKafka\Topic ] {
+        Method [ <internal:rdkafka> public method commit ] {
 
-      - Constants [0] {
-      }
+          - Parameters [1] {
+            Parameter #0 [ <optional> $message_or_offsets ]
+          }
+        }
 
-      - Static properties [0] {
-      }
+        Method [ <internal:rdkafka> public method commitAsync ] {
 
-      - Static methods [0] {
-      }
+          - Parameters [1] {
+            Parameter #0 [ <optional> $message_or_offsets ]
+          }
+        }
 
-      - Properties [0] {
-      }
+        Method [ <internal:rdkafka> public method consume ] {
 
-      - Methods [7] {
-        Method [ <internal:rdkafka, ctor> private method __construct ] {
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
 
-          - Parameters [0] {
+        Method [ <internal:rdkafka> public method subscribe ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $topics ]
           }
         }
 
-        Method [ <internal:rdkafka> public method consumeQueueStart ] {
+        Method [ <internal:rdkafka> public method getSubscription ] {
 
-          - Parameters [3] {
-            Parameter #0 [ <required> $partition ]
-            Parameter #1 [ <required> $offset ]
-            Parameter #2 [ <required> $queue ]
+          - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method consumeStart ] {
+        Method [ <internal:rdkafka> public method unsubscribe ] {
 
-          - Parameters [2] {
-            Parameter #0 [ <required> $partition ]
-            Parameter #1 [ <required> $offset ]
+          - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method consumeStop ] {
+        Method [ <internal:rdkafka> public method getMetadata ] {
 
-          - Parameters [1] {
-            Parameter #0 [ <required> $partition ]
+          - Parameters [3] {
+            Parameter #0 [ <required> $all_topics ]
+            Parameter #1 [ <required> $only_topic ]
+            Parameter #2 [ <required> $timeout_ms ]
           }
         }
 
-        Method [ <internal:rdkafka> public method consume ] {
+        Method [ <internal:rdkafka> public method newTopic ] {
 
           - Parameters [2] {
-            Parameter #0 [ <required> $partition ]
-            Parameter #1 [ <required> $timeout_ms ]
+            Parameter #0 [ <required> $topic_name ]
+            Parameter #1 [ <optional> $topic_conf ]
           }
         }
 
-        Method [ <internal:rdkafka> public method offsetStore ] {
+        Method [ <internal:rdkafka, dtor> final public method __destruct ] {
 
-          - Parameters [2] {
-            Parameter #0 [ <required> $partition ]
-            Parameter #1 [ <required> $offset ]
+          - Parameters [0] {
           }
         }
+      }
+    }
 
-        Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] {
+    Class [ <internal:rdkafka> class RdKafka\Message ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [6] {
+        Property [ <default> public $err ]
+        Property [ <default> public $topic_name ]
+        Property [ <default> public $partition ]
+        Property [ <default> public $payload ]
+        Property [ <default> public $key ]
+        Property [ <default> public $offset ]
+      }
+
+      - Methods [1] {
+        Method [ <internal:rdkafka> public method errstr ] {
 
           - Parameters [0] {
           }
@@ -500,7 +725,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       }
     }
 
-    Class [ <internal:rdkafka> class RdKafka\ProducerTopic extends RdKafka\Topic ] {
+    Class [ <internal:rdkafka> class RdKafka\Metadata ] {
 
       - Constants [0] {
       }
@@ -514,24 +739,26 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Properties [0] {
       }
 
-      - Methods [3] {
-        Method [ <internal:rdkafka, ctor> private method __construct ] {
+      - Methods [4] {
+        Method [ <internal:rdkafka> public method getOrigBrokerId ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method produce ] {
+        Method [ <internal:rdkafka> public method getOrigBrokerName ] {
 
-          - Parameters [4] {
-            Parameter #0 [ <required> $partition ]
-            Parameter #1 [ <required> $msgflags ]
-            Parameter #2 [ <required> $payload ]
-            Parameter #3 [ <optional> $key ]
+          - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] {
+        Method [ <internal:rdkafka> public method getBrokers ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getTopics ] {
 
           - Parameters [0] {
           }
@@ -539,7 +766,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       }
     }
 
-    Class [ <internal:rdkafka> class RdKafka\Message ] {
+    Class [ <internal:rdkafka> class RdKafka\Metadata\Topic ] {
 
       - Constants [0] {
       }
@@ -550,17 +777,23 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Static methods [0] {
       }
 
-      - Properties [6] {
-        Property [ <default> public $err ]
-        Property [ <default> public $topic_name ]
-        Property [ <default> public $partition ]
-        Property [ <default> public $payload ]
-        Property [ <default> public $key ]
-        Property [ <default> public $offset ]
+      - Properties [0] {
       }
 
-      - Methods [1] {
-        Method [ <internal:rdkafka> public method errstr ] {
+      - Methods [3] {
+        Method [ <internal:rdkafka> public method getTopic ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getPartitions ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getErr ] {
 
           - Parameters [0] {
           }
@@ -568,7 +801,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       }
     }
 
-    Class [ <internal:rdkafka> class RdKafka\Queue ] {
+    Class [ <internal:rdkafka> class RdKafka\Metadata\Broker ] {
 
       - Constants [0] {
       }
@@ -582,23 +815,28 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Properties [0] {
       }
 
-      - Methods [2] {
-        Method [ <internal:rdkafka, ctor> private method __construct ] {
+      - Methods [3] {
+        Method [ <internal:rdkafka> public method getId ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method consume ] {
+        Method [ <internal:rdkafka> public method getHost ] {
 
-          - Parameters [1] {
-            Parameter #0 [ <required> $timeout_ms ]
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getPort ] {
+
+          - Parameters [0] {
           }
         }
       }
     }
 
-    Class [ <internal:rdkafka> class RdKafka\Exception extends Exception ] {
+    Class [ <internal:rdkafka> class RdKafka\Metadata\Partition ] {
 
       - Constants [0] {
       }
@@ -609,53 +847,43 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Static methods [0] {
       }
 
-      - Properties [4] {
-        Property [ <default> protected $message ]
-        Property [ <default> protected $code ]
-        Property [ <default> protected $file ]
-        Property [ <default> protected $line ]
+      - Properties [0] {
       }
 
-      - Methods [10] {
-        Method [ <internal:Core, inherits Exception, ctor> <visibility error> method __construct ] {
+      - Methods [5] {
+        Method [ <internal:rdkafka> public method getId ] {
 
-          - Parameters [3] {
-            Parameter #0 [ <optional> $message ]
-            Parameter #1 [ <optional> $code ]
-            Parameter #2 [ <optional> $previous ]
+          - Parameters [0] {
           }
         }
 
-        Method [ <internal:Core, inherits Exception> public method __wakeup ] {
-        }
-
-        Method [ <internal:Core, inherits Exception> final public method getMessage ] {
-        }
+        Method [ <internal:rdkafka> public method getErr ] {
 
-        Method [ <internal:Core, inherits Exception> final public method getCode ] {
+          - Parameters [0] {
+          }
         }
 
-        Method [ <internal:Core, inherits Exception> final public method getFile ] {
-        }
+        Method [ <internal:rdkafka> public method getLeader ] {
 
-        Method [ <internal:Core, inherits Exception> final public method getLine ] {
+          - Parameters [0] {
+          }
         }
 
-        Method [ <internal:Core, inherits Exception> final public method getTrace ] {
-        }
+        Method [ <internal:rdkafka> public method getReplicas ] {
 
-        Method [ <internal:Core, inherits Exception> final public method getPrevious ] {
+          - Parameters [0] {
+          }
         }
 
-        Method [ <internal:Core, inherits Exception> final public method getTraceAsString ] {
-        }
+        Method [ <internal:rdkafka> public method getIsrs ] {
 
-        Method [ <internal:Core, inherits Exception> public method __toString ] {
+          - Parameters [0] {
+          }
         }
       }
     }
 
-    Class [ <internal:rdkafka> class RdKafka\Metadata ] {
+    Class [ <internal:rdkafka> <iterateable> class RdKafka\Metadata\Collection implements Countable, Iterator, Traversable ] {
 
       - Constants [0] {
       }
@@ -669,26 +897,38 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Properties [0] {
       }
 
-      - Methods [4] {
-        Method [ <internal:rdkafka> public method getOrigBrokerId ] {
+      - Methods [6] {
+        Method [ <internal:rdkafka, prototype Countable> public method count ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method getOrigBrokerName ] {
+        Method [ <internal:rdkafka, prototype Iterator> public method current ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method getBrokers ] {
+        Method [ <internal:rdkafka, prototype Iterator> public method key ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method getTopics ] {
+        Method [ <internal:rdkafka, prototype Iterator> public method next ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka, prototype Iterator> public method rewind ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:rdkafka, prototype Iterator> public method valid ] {
 
           - Parameters [0] {
           }
@@ -696,7 +936,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       }
     }
 
-    Class [ <internal:rdkafka> class RdKafka\Metadata\Topic ] {
+    Class [ <internal:rdkafka> class RdKafka\TopicPartition ] {
 
       - Constants [0] {
       }
@@ -710,28 +950,55 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Properties [0] {
       }
 
-      - Methods [3] {
+      - Methods [7] {
+        Method [ <internal:rdkafka, ctor> public method __construct ] {
+
+          - Parameters [0] {
+          }
+        }
+
         Method [ <internal:rdkafka> public method getTopic ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method getPartitions ] {
+        Method [ <internal:rdkafka> public method setTopic ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $topic_name ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getPartition ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method getErr ] {
+        Method [ <internal:rdkafka> public method setPartition ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $partition ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method getOffset ] {
 
           - Parameters [0] {
           }
         }
+
+        Method [ <internal:rdkafka> public method setOffset ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $offset ]
+          }
+        }
       }
     }
 
-    Class [ <internal:rdkafka> class RdKafka\Metadata\Broker ] {
+    Class [ <internal:rdkafka> class RdKafka\Queue ] {
 
       - Constants [0] {
       }
@@ -745,20 +1012,38 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Properties [0] {
       }
 
-      - Methods [3] {
-        Method [ <internal:rdkafka> public method getId ] {
+      - Methods [2] {
+        Method [ <internal:rdkafka, ctor> private method __construct ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method getHost ] {
+        Method [ <internal:rdkafka> public method consume ] {
 
-          - Parameters [0] {
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
           }
         }
+      }
+    }
 
-        Method [ <internal:rdkafka> public method getPort ] {
+    Class [ <internal:rdkafka> abstract class RdKafka\Topic ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [1] {
+        Method [ <internal:rdkafka> public method getName ] {
 
           - Parameters [0] {
           }
@@ -766,7 +1051,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       }
     }
 
-    Class [ <internal:rdkafka> class RdKafka\Metadata\Partition ] {
+    Class [ <internal:rdkafka> class RdKafka\ConsumerTopic extends RdKafka\Topic ] {
 
       - Constants [0] {
       }
@@ -780,32 +1065,54 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Properties [0] {
       }
 
-      - Methods [5] {
-        Method [ <internal:rdkafka> public method getId ] {
+      - Methods [7] {
+        Method [ <internal:rdkafka, ctor> private method __construct ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka> public method getErr ] {
+        Method [ <internal:rdkafka> public method consumeQueueStart ] {
 
-          - Parameters [0] {
+          - Parameters [3] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $offset ]
+            Parameter #2 [ <required> $queue ]
           }
         }
 
-        Method [ <internal:rdkafka> public method getLeader ] {
+        Method [ <internal:rdkafka> public method consumeStart ] {
 
-          - Parameters [0] {
+          - Parameters [2] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $offset ]
           }
         }
 
-        Method [ <internal:rdkafka> public method getReplicas ] {
+        Method [ <internal:rdkafka> public method consumeStop ] {
 
-          - Parameters [0] {
+          - Parameters [1] {
+            Parameter #0 [ <required> $partition ]
           }
         }
 
-        Method [ <internal:rdkafka> public method getIsrs ] {
+        Method [ <internal:rdkafka> public method consume ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method offsetStore ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $offset ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] {
 
           - Parameters [0] {
           }
@@ -813,7 +1120,7 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       }
     }
 
-    Class [ <internal:rdkafka> <iterateable> class RdKafka\Metadata\Collection implements Countable, Iterator, Traversable ] {
+    Class [ <internal:rdkafka> class RdKafka\KafkaConsumerTopic extends RdKafka\Topic ] {
 
       - Constants [0] {
       }
@@ -827,38 +1134,61 @@ Extension [ <persistent> extension #151 rdkafka version 0.9.1 ] {
       - Properties [0] {
       }
 
-      - Methods [6] {
-        Method [ <internal:rdkafka, prototype Countable> public method count ] {
+      - Methods [3] {
+        Method [ <internal:rdkafka, ctor> private method __construct ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka, prototype Iterator> public method current ] {
+        Method [ <internal:rdkafka> public method offsetStore ] {
 
-          - Parameters [0] {
+          - Parameters [2] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $offset ]
           }
         }
 
-        Method [ <internal:rdkafka, prototype Iterator> public method key ] {
+        Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] {
 
           - Parameters [0] {
           }
         }
+      }
+    }
 
-        Method [ <internal:rdkafka, prototype Iterator> public method next ] {
+    Class [ <internal:rdkafka> class RdKafka\ProducerTopic extends RdKafka\Topic ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [3] {
+        Method [ <internal:rdkafka, ctor> private method __construct ] {
 
           - Parameters [0] {
           }
         }
 
-        Method [ <internal:rdkafka, prototype Iterator> public method rewind ] {
+        Method [ <internal:rdkafka> public method produce ] {
 
-          - Parameters [0] {
+          - Parameters [4] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $msgflags ]
+            Parameter #2 [ <required> $payload ]
+            Parameter #3 [ <optional> $key ]
           }
         }
 
-        Method [ <internal:rdkafka, prototype Iterator> public method valid ] {
+        Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] {
 
           - Parameters [0] {
           }