New package

1 files changed, 1055 insertions, 0 deletions

diff --git a/REFLECTION b/REFLECTION
new file mode 100644
index 0000000..917efb0
--- /dev/null
+++ b/REFLECTION
@@ -0,0 +1,1055 @@
+Extension [ <persistent> extension #101 simple_kafka_client version 0.1.1 ] {
+
+  - Functions {
+    Function [ <internal:simple_kafka_client> function kafka_get_err_descs ] {
+
+      - Parameters [0] {
+      }
+      - Return [ array ]
+    }
+    Function [ <internal:simple_kafka_client> function kafka_err2str ] {
+
+      - Parameters [1] {
+        Parameter #0 [ <required> int $errorCode ]
+      }
+      - Return [ string ]
+    }
+    Function [ <internal:simple_kafka_client> function kafka_thread_cnt ] {
+
+      - Parameters [0] {
+      }
+      - Return [ int ]
+    }
+    Function [ <internal:simple_kafka_client> function kafka_offset_tail ] {
+
+      - Parameters [1] {
+        Parameter #0 [ <required> int $offset ]
+      }
+      - Return [ int ]
+    }
+    Function [ <internal:simple_kafka_client> function kafka_err2name ] {
+
+      - Parameters [1] {
+        Parameter #0 [ <required> int $errorCode ]
+      }
+      - Return [ string ]
+    }
+  }
+
+  - Classes [16] {
+    Class [ <internal:simple_kafka_client> abstract class SimpleKafkaClient ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [5] {
+        Method [ <internal:simple_kafka_client> public method getMetadata ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> bool $allTopics ]
+            Parameter #1 [ <required> int $timeoutMs ]
+            Parameter #2 [ <required> SimpleKafkaClient\Topic $topic ]
+          }
+          - Return [ SimpleKafkaClient\Metadata ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getOutQLen ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method poll ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> int $timeoutMs ]
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method queryWatermarkOffsets ] {
+
+          - Parameters [5] {
+            Parameter #0 [ <required> string $topic ]
+            Parameter #1 [ <required> int $partition ]
+            Parameter #2 [ <required> int &$low ]
+            Parameter #3 [ <required> int &$high ]
+            Parameter #4 [ <required> int $timeoutMs ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> array $topicPartitions ]
+            Parameter #1 [ <required> int $timeoutMs ]
+          }
+          - Return [ array ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Producer extends SimpleKafkaClient ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [13] {
+        Method [ <internal:simple_kafka_client, ctor> public method __construct ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> SimpleKafkaClient\Configuration $configuration ]
+          }
+        }
+
+        Method [ <internal:simple_kafka_client> public method initTransactions ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> int $timeoutMs ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method beginTransaction ] {
+
+          - Parameters [0] {
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method commitTransaction ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> int $timeoutMs ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method abortTransaction ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> int $timeoutMs ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method flush ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> int $timeoutMs ]
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method purge ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> int $purgeFlags ]
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getTopicHandle ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> string $topic ]
+          }
+          - Return [ SimpleKafkaClient\ProducerTopic ]
+        }
+
+        Method [ <internal:simple_kafka_client, inherits SimpleKafkaClient> public method getMetadata ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> bool $allTopics ]
+            Parameter #1 [ <required> int $timeoutMs ]
+            Parameter #2 [ <required> SimpleKafkaClient\Topic $topic ]
+          }
+          - Return [ SimpleKafkaClient\Metadata ]
+        }
+
+        Method [ <internal:simple_kafka_client, inherits SimpleKafkaClient> public method getOutQLen ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client, inherits SimpleKafkaClient> public method poll ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> int $timeoutMs ]
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client, inherits SimpleKafkaClient> public method queryWatermarkOffsets ] {
+
+          - Parameters [5] {
+            Parameter #0 [ <required> string $topic ]
+            Parameter #1 [ <required> int $partition ]
+            Parameter #2 [ <required> int &$low ]
+            Parameter #3 [ <required> int &$high ]
+            Parameter #4 [ <required> int $timeoutMs ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client, inherits SimpleKafkaClient> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> array $topicPartitions ]
+            Parameter #1 [ <required> int $timeoutMs ]
+          }
+          - Return [ array ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Configuration ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [9] {
+        Method [ <internal:simple_kafka_client, ctor> public method __construct ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:simple_kafka_client> public method dump ] {
+
+          - Parameters [0] {
+          }
+          - Return [ array ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method set ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> string $name ]
+            Parameter #1 [ <required> string $value ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method setErrorCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> callable $callback ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method setDrMsgCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> callable $callback ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method setStatsCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> callable $callback ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method setRebalanceCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> callable $callback ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method setOffsetCommitCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> callable $callback ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method setLogCb ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> callable $callback ]
+          }
+          - Return [ void ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Exception extends Exception implements Throwable ] {
+
+      - 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, prototype Throwable> final public method getMessage ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> public method __toString ] {
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\KafkaErrorException extends SimpleKafkaClient\Exception implements Throwable ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [8] {
+        Property [ <default> protected $message ]
+        Property [ <default> protected $code ]
+        Property [ <default> protected $file ]
+        Property [ <default> protected $line ]
+        Property [ <default> private $error_string ]
+        Property [ <default> private $isFatal ]
+        Property [ <default> private $isRetriable ]
+        Property [ <default> private $transactionRequiresAbort ]
+      }
+
+      - Methods [14] {
+        Method [ <internal:simple_kafka_client, overwrites Exception, ctor> public method __construct ] {
+
+          - Parameters [6] {
+            Parameter #0 [ <required> string $message ]
+            Parameter #1 [ <required> int $code ]
+            Parameter #2 [ <required> string $error_string ]
+            Parameter #3 [ <required> bool $isFatal ]
+            Parameter #4 [ <required> bool $isRetriable ]
+            Parameter #5 [ <required> bool $transactionRequiresAbort ]
+          }
+        }
+
+        Method [ <internal:simple_kafka_client> public method getErrorString ] {
+
+          - Parameters [0] {
+          }
+          - Return [ string ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method isFatal ] {
+
+          - Parameters [0] {
+          }
+          - Return [ bool ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method isRetriable ] {
+
+          - Parameters [0] {
+          }
+          - Return [ bool ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method transactionRequiresAbort ] {
+
+          - Parameters [0] {
+          }
+          - Return [ bool ]
+        }
+
+        Method [ <internal:Core, inherits Exception> public method __wakeup ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getMessage ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getCode ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getFile ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getLine ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTrace ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getPrevious ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> final public method getTraceAsString ] {
+        }
+
+        Method [ <internal:Core, inherits Exception, prototype Throwable> public method __toString ] {
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Consumer ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [16] {
+        Method [ <internal:simple_kafka_client, ctor> public method __construct ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> SimpleKafkaClient\Configuration $configuration ]
+          }
+        }
+
+        Method [ <internal:simple_kafka_client> public method assign ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> array or NULL $topics ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getAssignment ] {
+
+          - Parameters [0] {
+          }
+          - Return [ array ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method subscribe ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> array $topics ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getSubscription ] {
+
+          - Parameters [0] {
+          }
+          - Return [ array ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method unsubscribe ] {
+
+          - Parameters [0] {
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method consume ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> int $timeoutMs ]
+          }
+          - Return [ SimpleKafkaClient\Message ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method commit ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $messageOrOffsets ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method commitAsync ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> $messageOrOffsets ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method close ] {
+
+          - Parameters [0] {
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getMetadata ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> bool $allTopics ]
+            Parameter #1 [ <required> int $timeoutMs ]
+            Parameter #2 [ <required> SimpleKafkaClient\ConsumerTopic $topic ]
+          }
+          - Return [ SimpleKafkaClient\Metadata ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getTopicHandle ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> string $topic ]
+          }
+          - Return [ SimpleKafkaClient\ConsumerTopic ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getCommittedOffsets ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> array $topics ]
+            Parameter #1 [ <required> int $timeoutMs ]
+          }
+          - Return [ array ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getOffsetPositions ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> array $topics ]
+          }
+          - Return [ array ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method offsetsForTimes ] {
+
+          - Parameters [2] {
+            Parameter #0 [ <required> array $topicPartitions ]
+            Parameter #1 [ <required> int $timeoutMs ]
+          }
+          - Return [ array ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method queryWatermarkOffsets ] {
+
+          - Parameters [5] {
+            Parameter #0 [ <required> string $topic ]
+            Parameter #1 [ <required> int $partition ]
+            Parameter #2 [ <required> int &$low ]
+            Parameter #3 [ <required> int &$high ]
+            Parameter #4 [ <required> int $timeoutMs ]
+          }
+          - Return [ void ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Message ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [9] {
+        Property [ <default> public $err ]
+        Property [ <default> public $topic_name ]
+        Property [ <default> public $timestamp ]
+        Property [ <default> public $partition ]
+        Property [ <default> public $payload ]
+        Property [ <default> public $len ]
+        Property [ <default> public $key ]
+        Property [ <default> public $offset ]
+        Property [ <default> public $headers ]
+      }
+
+      - Methods [1] {
+        Method [ <internal:simple_kafka_client> public method getErrorString ] {
+
+          - Parameters [0] {
+          }
+          - Return [ string ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Metadata ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [4] {
+        Method [ <internal:simple_kafka_client> public method getOrigBrokerId ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getOrigBrokerName ] {
+
+          - Parameters [0] {
+          }
+          - Return [ string ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getBrokers ] {
+
+          - Parameters [0] {
+          }
+          - Return [ SimpleKafkaClient\Metadata\Collection ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getTopics ] {
+
+          - Parameters [0] {
+          }
+          - Return [ SimpleKafkaClient\Metadata\Collection ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Metadata\Topic ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [3] {
+        Method [ <internal:simple_kafka_client> public method getName ] {
+
+          - Parameters [0] {
+          }
+          - Return [ string ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getErrorCode ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getPartitions ] {
+
+          - Parameters [0] {
+          }
+          - Return [ SimpleKafkaClient\Metadata\Collection ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Metadata\Broker ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [3] {
+        Method [ <internal:simple_kafka_client> public method getId ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getHost ] {
+
+          - Parameters [0] {
+          }
+          - Return [ string ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getPort ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\Metadata\Partition ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [5] {
+        Method [ <internal:simple_kafka_client> public method getId ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getErrorCode ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getLeader ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getReplicas ] {
+
+          - Parameters [0] {
+          }
+          - Return [ SimpleKafkaClient\Metadata\Collection ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getIsrs ] {
+
+          - Parameters [0] {
+          }
+          - Return [ SimpleKafkaClient\Metadata\Collection ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> <iterateable> class SimpleKafkaClient\Metadata\Collection implements Countable, Iterator, Traversable ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [6] {
+        Method [ <internal:simple_kafka_client, prototype Countable> public method count ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client, prototype Iterator> public method rewind ] {
+
+          - Parameters [0] {
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client, prototype Iterator> public method current ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:simple_kafka_client, prototype Iterator> public method key ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client, prototype Iterator> public method next ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:simple_kafka_client, prototype Iterator> public method valid ] {
+
+          - Parameters [0] {
+          }
+          - Return [ bool ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\TopicPartition ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [7] {
+        Method [ <internal:simple_kafka_client, ctor> public method __construct ] {
+
+          - Parameters [3] {
+            Parameter #0 [ <required> string $topicName ]
+            Parameter #1 [ <required> int $partition ]
+            Parameter #2 [ <optional> $offset ]
+          }
+        }
+
+        Method [ <internal:simple_kafka_client> public method getTopicName ] {
+
+          - Parameters [0] {
+          }
+          - Return [ string or NULL ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method setTopicName ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> string $topicName ]
+          }
+          - Return [ SimpleKafkaClient\TopicPartition ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getPartition ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method setPartition ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> int $partition ]
+          }
+          - Return [ SimpleKafkaClient\TopicPartition ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method getOffset ] {
+
+          - Parameters [0] {
+          }
+          - Return [ int ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method setOffset ] {
+
+          - Parameters [1] {
+            Parameter #0 [ <required> int $offset ]
+          }
+          - Return [ SimpleKafkaClient\TopicPartition ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> abstract class SimpleKafkaClient\Topic ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [1] {
+        Method [ <internal:simple_kafka_client> public method getName ] {
+
+          - Parameters [0] {
+          }
+          - Return [ string ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\ConsumerTopic extends SimpleKafkaClient\Topic ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [2] {
+        Method [ <internal:simple_kafka_client, ctor> private method __construct ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:simple_kafka_client, inherits SimpleKafkaClient\Topic> public method getName ] {
+
+          - Parameters [0] {
+          }
+          - Return [ string ]
+        }
+      }
+    }
+
+    Class [ <internal:simple_kafka_client> class SimpleKafkaClient\ProducerTopic extends SimpleKafkaClient\Topic ] {
+
+      - Constants [0] {
+      }
+
+      - Static properties [0] {
+      }
+
+      - Static methods [0] {
+      }
+
+      - Properties [0] {
+      }
+
+      - Methods [4] {
+        Method [ <internal:simple_kafka_client, ctor> private method __construct ] {
+
+          - Parameters [0] {
+          }
+        }
+
+        Method [ <internal:simple_kafka_client> public method produce ] {
+
+          - Parameters [4] {
+            Parameter #0 [ <required> int $partition ]
+            Parameter #1 [ <required> int $msgFlags ]
+            Parameter #2 [ <optional> $payload ]
+            Parameter #3 [ <optional> $key ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client> public method producev ] {
+
+          - Parameters [6] {
+            Parameter #0 [ <required> int $partition ]
+            Parameter #1 [ <required> int $msgFlags ]
+            Parameter #2 [ <optional> $payload ]
+            Parameter #3 [ <optional> $key ]
+            Parameter #4 [ <optional> $headers ]
+            Parameter #5 [ <optional> $timestampMs ]
+          }
+          - Return [ void ]
+        }
+
+        Method [ <internal:simple_kafka_client, inherits SimpleKafkaClient\Topic> public method getName ] {
+
+          - Parameters [0] {
+          }
+          - Return [ string ]
+        }
+      }
+    }
+  }
+}
+