- update to 4.0.0

- rename to php-pecl-rdkafka4
- raise dependency on librdkafka 0.11

1 files changed, 150 insertions, 38 deletions

diff --git a/REFLECTION b/REFLECTION
index 7c6f71c..7ec44e4 100644
--- a/REFLECTION
+++ b/REFLECTION
@@ -1,14 +1,18 @@
-Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
+Extension [ <persistent> extension #136 rdkafka version 4.0.0 ] {
 
-  - Constants [154] {
+  - Constants [161] {
     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 ] { 16843007 }
-    Constant [ integer RD_KAFKA_BUILD_VERSION ] { 16843007 }
+    Constant [ integer RD_KAFKA_MSG_F_BLOCK ] { 4 }
+    Constant [ integer RD_KAFKA_PURGE_F_QUEUE ] { 1 }
+    Constant [ integer RD_KAFKA_PURGE_F_INFLIGHT ] { 2 }
+    Constant [ integer RD_KAFKA_PURGE_F_NON_BLOCKING ] { 4 }
+    Constant [ integer RD_KAFKA_VERSION ] { 16908543 }
+    Constant [ integer RD_KAFKA_BUILD_VERSION ] { 16908543 }
     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 }
@@ -152,6 +156,9 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
     Constant [ integer RD_KAFKA_CONF_OK ] { 0 }
     Constant [ integer RD_KAFKA_MSG_PARTITIONER_RANDOM ] { 2 }
     Constant [ integer RD_KAFKA_MSG_PARTITIONER_CONSISTENT ] { 3 }
+    Constant [ integer RD_KAFKA_MSG_PARTITIONER_CONSISTENT_RANDOM ] { 4 }
+    Constant [ integer RD_KAFKA_MSG_PARTITIONER_MURMUR2 ] { 5 }
+    Constant [ integer RD_KAFKA_MSG_PARTITIONER_MURMUR2_RANDOM ] { 6 }
     Constant [ integer RD_KAFKA_LOG_PRINT ] { 100 }
     Constant [ integer RD_KAFKA_LOG_SYSLOG ] { 101 }
     Constant [ integer RD_KAFKA_LOG_SYSLOG_PRINT ] { 102 }
@@ -169,13 +176,13 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
         Parameter #0 [ <required> $err ]
       }
     }
-    Function [ <internal:rdkafka> function rd_kafka_errno2err ] {
+    Function [ <internal, deprecated:rdkafka> function rd_kafka_errno2err ] {
 
       - Parameters [1] {
         Parameter #0 [ <required> $errnox ]
       }
     }
-    Function [ <internal:rdkafka> function rd_kafka_errno ] {
+    Function [ <internal, deprecated:rdkafka> function rd_kafka_errno ] {
 
       - Parameters [0] {
       }
@@ -210,7 +217,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
         Property [ <default> private $dr_cb ]
       }
 
-      - Methods [11] {
+      - Methods [13] {
         Method [ <internal:rdkafka> public method addBrokers ] {
 
           - Parameters [1] {
@@ -242,19 +249,13 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
           }
         }
 
-        Method [ <internal:rdkafka> public method setLogLevel ] {
+        Method [ <internal, deprecated:rdkafka> public method setLogLevel ] {
 
           - Parameters [1] {
             Parameter #0 [ <required> $level ]
           }
         }
 
-        Method [ <internal:rdkafka> public method newQueue ] {
-
-          - Parameters [0] {
-          }
-        }
-
         Method [ <internal:rdkafka> public method newTopic ] {
 
           - Parameters [2] {
@@ -276,7 +277,21 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
           }
         }
 
-        Method [ <internal:rdkafka> public method setLogger ] {
+        Method [ <internal:rdkafka> public method flush ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method purge ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $purge_flags ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka> public method setLogger ] {
 
           - Parameters [1] {
             Parameter #0 [ <required> $logger ]
@@ -293,6 +308,14 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
             Parameter #4 [ <optional> $timeout_ms ]
           }
         }
+
+        Method [ <internal:rdkafka> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_partitions ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
       }
     }
 
@@ -310,7 +333,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
       - Properties [0] {
       }
 
-      - Methods [12] {
+      - Methods [15] {
         Method [ <internal:rdkafka, ctor> public method __construct ] {
 
           - Parameters [1] {
@@ -318,6 +341,12 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
           }
         }
 
+        Method [ <internal:rdkafka> public method newQueue ] {
+
+          - Parameters [0] {
+          }
+        }
+
         Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] {
 
           - Parameters [1] {
@@ -349,19 +378,13 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka> public method setLogLevel ] {
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] {
 
           - Parameters [1] {
             Parameter #0 [ <required> $level ]
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka> public method newQueue ] {
-
-          - Parameters [0] {
-          }
-        }
-
         Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] {
 
           - Parameters [2] {
@@ -383,7 +406,21 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka> public method setLogger ] {
+        Method [ <internal:rdkafka, inherits RdKafka> public method flush ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method purge ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $purge_flags ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogger ] {
 
           - Parameters [1] {
             Parameter #0 [ <required> $logger ]
@@ -400,6 +437,14 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
             Parameter #4 [ <optional> $timeout_ms ]
           }
         }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_partitions ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
       }
     }
 
@@ -417,7 +462,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
       - Properties [0] {
       }
 
-      - Methods [12] {
+      - Methods [14] {
         Method [ <internal:rdkafka, ctor> public method __construct ] {
 
           - Parameters [1] {
@@ -456,19 +501,13 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka> public method setLogLevel ] {
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] {
 
           - Parameters [1] {
             Parameter #0 [ <required> $level ]
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka> public method newQueue ] {
-
-          - Parameters [0] {
-          }
-        }
-
         Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] {
 
           - Parameters [2] {
@@ -490,7 +529,21 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
           }
         }
 
-        Method [ <internal:rdkafka, inherits RdKafka> public method setLogger ] {
+        Method [ <internal:rdkafka, inherits RdKafka> public method flush ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method purge ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $purge_flags ]
+          }
+        }
+
+        Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogger ] {
 
           - Parameters [1] {
             Parameter #0 [ <required> $logger ]
@@ -507,6 +560,14 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
             Parameter #4 [ <optional> $timeout_ms ]
           }
         }
+
+        Method [ <internal:rdkafka, inherits RdKafka> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_partitions ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
       }
     }
 
@@ -581,7 +642,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
       - Properties [0] {
       }
 
-      - Methods [10] {
+      - Methods [11] {
         Method [ <internal:rdkafka, ctor> public method __construct ] {
 
           - Parameters [0] {
@@ -602,7 +663,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
           }
         }
 
-        Method [ <internal:rdkafka> public method setDefaultTopicConf ] {
+        Method [ <internal, deprecated:rdkafka> public method setDefaultTopicConf ] {
 
           - Parameters [1] {
             Parameter #0 [ <required> $topic_conf ]
@@ -650,6 +711,13 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
             Parameter #0 [ <required> $callback ]
           }
         }
+
+        Method [ <internal:rdkafka> public method setLogCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $callback ]
+          }
+        }
       }
     }
 
@@ -714,7 +782,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
         Property [ <default> private $dr_msg_cb ]
       }
 
-      - Methods [12] {
+      - Methods [16] {
         Method [ <internal:rdkafka, ctor> public method __construct ] {
 
           - Parameters [1] {
@@ -742,6 +810,12 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
           }
         }
 
+        Method [ <internal:rdkafka> public method close ] {
+
+          - Parameters [0] {
+          }
+        }
+
         Method [ <internal:rdkafka> public method commitAsync ] {
 
           - Parameters [1] {
@@ -799,6 +873,32 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
             Parameter #1 [ <required> $timeout_ms ]
           }
         }
+
+        Method [ <internal:rdkafka> public method getOffsetPositions ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $topic_partitions ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method queryWatermarkOffsets ] {
+
+          - Parameters [5] {
+            Parameter #0 [ <required> $topic ]
+            Parameter #1 [ <optional> $partition ]
+            Parameter #2 [ <optional> &$low ]
+            Parameter #3 [ <optional> &$high ]
+            Parameter #4 [ <optional> $timeout_ms ]
+          }
+        }
+
+        Method [ <internal:rdkafka> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> $topic_partitions ]
+            Parameter #1 [ <required> $timeout_ms ]
+          }
+        }
       }
     }
 
@@ -1062,7 +1162,10 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
       - Methods [7] {
         Method [ <internal:rdkafka, ctor> public method __construct ] {
 
-          - Parameters [0] {
+          - Parameters [3] {
+            Parameter #0 [ <required> $topic ]
+            Parameter #1 [ <required> $partition ]
+            Parameter #2 [ <optional> $offset ]
           }
         }
 
@@ -1174,7 +1277,7 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
       - Properties [0] {
       }
 
-      - Methods [7] {
+      - Methods [8] {
         Method [ <internal:rdkafka, ctor> private method __construct ] {
 
           - Parameters [0] {
@@ -1213,6 +1316,15 @@ Extension [ <persistent> extension #136 rdkafka version 3.1.2 ] {
           }
         }
 
+        Method [ <internal:rdkafka> public method consumeBatch ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> $partition ]
+            Parameter #1 [ <required> $timeout_ms ]
+            Parameter #2 [ <required> $batch_size ]
+          }
+        }
+
         Method [ <internal:rdkafka> public method offsetStore ] {
 
           - Parameters [2] {