Skip to content

Commit c6f0317

Browse files
nick-zhnick-zh
authored
extend properly, remove duplicate code (#46)
* extend properly, remove duplicate code * add new arginfo, add offsets test * fix test, move poll * fix func args and add test * fix test * fix test
1 parent e96a76b commit c6f0317

12 files changed

+102
-184
lines changed

‎consumer.c‎

Lines changed: 0 additions & 118 deletions
Original file line numberDiff line numberDiff line change
@@ -433,48 +433,6 @@ ZEND_METHOD(SimpleKafkaClient_Consumer, close)
433433
}
434434
/* }}} */
435435

436-
/* {{{ proto Metadata SimpleKafkaClient\Consumer::getMetadata(bool all_topics, int timeout_ms, SimpleKafkaClient\Topic only_topic = null)
437-
Request Metadata from broker */
438-
ZEND_METHOD(SimpleKafkaClient_Consumer, getMetadata)
439-
{
440-
zend_bool all_topics;
441-
zval *only_zrkt = NULL;
442-
zend_long timeout_ms;
443-
rd_kafka_resp_err_t err;
444-
kafka_object *intern;
445-
const rd_kafka_metadata_t *metadata;
446-
kafka_topic_object *only_orkt = NULL;
447-
448-
ZEND_PARSE_PARAMETERS_START_EX(ZEND_PARSE_PARAMS_THROW, 2, 3)
449-
Z_PARAM_BOOL(all_topics)
450-
Z_PARAM_LONG(timeout_ms)
451-
Z_PARAM_OPTIONAL
452-
Z_PARAM_OBJECT_OF_CLASS(only_zrkt, ce_kafka_topic)
453-
ZEND_PARSE_PARAMETERS_END();
454-
455-
intern = get_kafka_object(getThis());
456-
if (!intern) {
457-
return;
458-
}
459-
460-
if (only_zrkt) {
461-
only_orkt = get_kafka_topic_object(only_zrkt);
462-
if (!only_orkt) {
463-
return;
464-
}
465-
}
466-
467-
err = rd_kafka_metadata(intern->rk, all_topics, only_orkt ? only_orkt->rkt : NULL, &metadata, timeout_ms);
468-
469-
if (err != RD_KAFKA_RESP_ERR_NO_ERROR) {
470-
zend_throw_exception(ce_kafka_exception, rd_kafka_err2str(err), err);
471-
return;
472-
}
473-
474-
kafka_metadata_obj_init(return_value, metadata);
475-
}
476-
/* }}} */
477-
478436
/* {{{ proto SimpleKafkaClient\ConsumerTopic SimpleKafkaClient\Consumer::getTopicHandle(string $topic)
479437
Returns a SimpleKafkaClient\ConsumerTopic object */
480438
ZEND_METHOD(SimpleKafkaClient_Consumer, getTopicHandle)
@@ -587,79 +545,3 @@ ZEND_METHOD(SimpleKafkaClient_Consumer, getOffsetPositions)
587545
}
588546
/* }}} */
589547

590-
/* {{{ proto void SimpleKafkaClient\Consumer::offsetsForTimes(array $topicPartitions, int $timeout_ms)
591-
Look up the offsets for the given partitions by timestamp. */
592-
ZEND_METHOD(SimpleKafkaClient_Consumer, offsetsForTimes)
593-
{
594-
HashTable *htopars = NULL;
595-
kafka_object *intern;
596-
rd_kafka_topic_partition_list_t *topicPartitions;
597-
zend_long timeout_ms;
598-
rd_kafka_resp_err_t err;
599-
600-
ZEND_PARSE_PARAMETERS_START_EX(ZEND_PARSE_PARAMS_THROW, 2, 2)
601-
Z_PARAM_ARRAY_HT(htopars)
602-
Z_PARAM_LONG(timeout_ms)
603-
ZEND_PARSE_PARAMETERS_END();
604-
605-
intern = get_kafka_object(getThis());
606-
if (!intern) {
607-
return;
608-
}
609-
610-
topicPartitions = array_arg_to_kafka_topic_partition_list(1, htopars);
611-
if (!topicPartitions) {
612-
return;
613-
}
614-
615-
err = rd_kafka_offsets_for_times(intern->rk, topicPartitions, timeout_ms);
616-
617-
if (err != RD_KAFKA_RESP_ERR_NO_ERROR) {
618-
rd_kafka_topic_partition_list_destroy(topicPartitions);
619-
zend_throw_exception(ce_kafka_exception, rd_kafka_err2str(err), err);
620-
return;
621-
}
622-
kafka_topic_partition_list_to_array(return_value, topicPartitions);
623-
rd_kafka_topic_partition_list_destroy(topicPartitions);
624-
}
625-
/* }}} */
626-
627-
/* {{{ proto void SimpleKafkaClient\Consumer::queryWatermarkOffsets(string $topic, int $partition, int &$low, int &$high, int $timeout_ms)
628-
Query broker for low (oldest/beginning) or high (newest/end) offsets for partition */
629-
ZEND_METHOD(SimpleKafkaClient_Consumer, queryWatermarkOffsets)
630-
{
631-
kafka_object *intern;
632-
char *topic;
633-
size_t topic_length;
634-
long low, high;
635-
zend_long partition, timeout_ms;
636-
zval *lowResult, *highResult;
637-
rd_kafka_resp_err_t err;
638-
639-
ZEND_PARSE_PARAMETERS_START_EX(ZEND_PARSE_PARAMS_THROW, 2, 2)
640-
Z_PARAM_STRING(topic, topic_length)
641-
Z_PARAM_LONG(partition)
642-
Z_PARAM_ZVAL(lowResult)
643-
Z_PARAM_ZVAL(highResult)
644-
Z_PARAM_LONG(timeout_ms)
645-
ZEND_PARSE_PARAMETERS_END();
646-
647-
ZVAL_DEREF(lowResult);
648-
ZVAL_DEREF(highResult);
649-
650-
intern = get_kafka_object(getThis());
651-
if (!intern) {
652-
return;
653-
}
654-
655-
err = rd_kafka_query_watermark_offsets(intern->rk, topic, partition, &low, &high, timeout_ms);
656-
657-
if (err != RD_KAFKA_RESP_ERR_NO_ERROR) {
658-
zend_throw_exception(ce_kafka_exception, rd_kafka_err2str(err), err);
659-
return;
660-
}
661-
662-
ZVAL_LONG(lowResult, low);
663-
ZVAL_LONG(highResult, high);
664-
}
665-
/* }}} */

‎consumer.stub.php‎

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -28,15 +28,9 @@ public function commitAsync($messageOrOffsets): void {}
2828

2929
public function close(): void {}
3030

31-
public function getMetadata(bool $allTopics, int $timeoutMs, ConsumerTopic $topic): Metadata {}
32-
3331
public function getTopicHandle(string $topic): ConsumerTopic {}
3432

3533
public function getCommittedOffsets(array $topics, int $timeoutMs): array {}
3634

3735
public function getOffsetPositions(array $topics): array {}
38-
39-
public function offsetsForTimes(array $topicPartitions, int $timeoutMs): array {}
40-
41-
public function queryWatermarkOffsets(string $topic, int $partition, int &$low, int &$high, int $timeoutMs): void {}
4236
}

‎consumer_arginfo.h‎

Lines changed: 1 addition & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/* This is a generated file, edit the .stub.php file instead.
2-
* Stub hash: 091c6b60081bb08ec174ef87b9cc6d2b3fbba461 */
2+
* Stub hash: 378cc029a3673afe02572e7e17fde17e47b2aefd */
33

44
ZEND_BEGIN_ARG_INFO_EX(arginfo_class_SimpleKafkaClient_Consumer___construct, 0, 0, 1)
55
ZEND_ARG_OBJ_INFO(0, configuration, SimpleKafkaClient\\Configuration, 0)
@@ -33,12 +33,6 @@ ZEND_END_ARG_INFO()
3333

3434
#define arginfo_class_SimpleKafkaClient_Consumer_close arginfo_class_SimpleKafkaClient_Consumer_unsubscribe
3535

36-
ZEND_BEGIN_ARG_WITH_RETURN_OBJ_INFO_EX(arginfo_class_SimpleKafkaClient_Consumer_getMetadata, 0, 3, SimpleKafkaClient\\Metadata, 0)
37-
ZEND_ARG_TYPE_INFO(0, allTopics, _IS_BOOL, 0)
38-
ZEND_ARG_TYPE_INFO(0, timeoutMs, IS_LONG, 0)
39-
ZEND_ARG_OBJ_INFO(0, topic, SimpleKafkaClient\\ConsumerTopic, 0)
40-
ZEND_END_ARG_INFO()
41-
4236
ZEND_BEGIN_ARG_WITH_RETURN_OBJ_INFO_EX(arginfo_class_SimpleKafkaClient_Consumer_getTopicHandle, 0, 1, SimpleKafkaClient\\ConsumerTopic, 0)
4337
ZEND_ARG_TYPE_INFO(0, topic, IS_STRING, 0)
4438
ZEND_END_ARG_INFO()
@@ -52,19 +46,6 @@ ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_class_SimpleKafkaClient_Consumer
5246
ZEND_ARG_TYPE_INFO(0, topics, IS_ARRAY, 0)
5347
ZEND_END_ARG_INFO()
5448

55-
ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_class_SimpleKafkaClient_Consumer_offsetsForTimes, 0, 2, IS_ARRAY, 0)
56-
ZEND_ARG_TYPE_INFO(0, topicPartitions, IS_ARRAY, 0)
57-
ZEND_ARG_TYPE_INFO(0, timeoutMs, IS_LONG, 0)
58-
ZEND_END_ARG_INFO()
59-
60-
ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_class_SimpleKafkaClient_Consumer_queryWatermarkOffsets, 0, 5, IS_VOID, 0)
61-
ZEND_ARG_TYPE_INFO(0, topic, IS_STRING, 0)
62-
ZEND_ARG_TYPE_INFO(0, partition, IS_LONG, 0)
63-
ZEND_ARG_TYPE_INFO(1, low, IS_LONG, 0)
64-
ZEND_ARG_TYPE_INFO(1, high, IS_LONG, 0)
65-
ZEND_ARG_TYPE_INFO(0, timeoutMs, IS_LONG, 0)
66-
ZEND_END_ARG_INFO()
67-
6849

6950
ZEND_METHOD(SimpleKafkaClient_Consumer, __construct);
7051
ZEND_METHOD(SimpleKafkaClient_Consumer, assign);
@@ -76,12 +57,9 @@ ZEND_METHOD(SimpleKafkaClient_Consumer, consume);
7657
ZEND_METHOD(SimpleKafkaClient_Consumer, commit);
7758
ZEND_METHOD(SimpleKafkaClient_Consumer, commitAsync);
7859
ZEND_METHOD(SimpleKafkaClient_Consumer, close);
79-
ZEND_METHOD(SimpleKafkaClient_Consumer, getMetadata);
8060
ZEND_METHOD(SimpleKafkaClient_Consumer, getTopicHandle);
8161
ZEND_METHOD(SimpleKafkaClient_Consumer, getCommittedOffsets);
8262
ZEND_METHOD(SimpleKafkaClient_Consumer, getOffsetPositions);
83-
ZEND_METHOD(SimpleKafkaClient_Consumer, offsetsForTimes);
84-
ZEND_METHOD(SimpleKafkaClient_Consumer, queryWatermarkOffsets);
8563

8664

8765
static const zend_function_entry class_SimpleKafkaClient_Consumer_methods[] = {
@@ -95,11 +73,8 @@ static const zend_function_entry class_SimpleKafkaClient_Consumer_methods[] = {
9573
ZEND_ME(SimpleKafkaClient_Consumer, commit, arginfo_class_SimpleKafkaClient_Consumer_commit, ZEND_ACC_PUBLIC)
9674
ZEND_ME(SimpleKafkaClient_Consumer, commitAsync, arginfo_class_SimpleKafkaClient_Consumer_commitAsync, ZEND_ACC_PUBLIC)
9775
ZEND_ME(SimpleKafkaClient_Consumer, close, arginfo_class_SimpleKafkaClient_Consumer_close, ZEND_ACC_PUBLIC)
98-
ZEND_ME(SimpleKafkaClient_Consumer, getMetadata, arginfo_class_SimpleKafkaClient_Consumer_getMetadata, ZEND_ACC_PUBLIC)
9976
ZEND_ME(SimpleKafkaClient_Consumer, getTopicHandle, arginfo_class_SimpleKafkaClient_Consumer_getTopicHandle, ZEND_ACC_PUBLIC)
10077
ZEND_ME(SimpleKafkaClient_Consumer, getCommittedOffsets, arginfo_class_SimpleKafkaClient_Consumer_getCommittedOffsets, ZEND_ACC_PUBLIC)
10178
ZEND_ME(SimpleKafkaClient_Consumer, getOffsetPositions, arginfo_class_SimpleKafkaClient_Consumer_getOffsetPositions, ZEND_ACC_PUBLIC)
102-
ZEND_ME(SimpleKafkaClient_Consumer, offsetsForTimes, arginfo_class_SimpleKafkaClient_Consumer_offsetsForTimes, ZEND_ACC_PUBLIC)
103-
ZEND_ME(SimpleKafkaClient_Consumer, queryWatermarkOffsets, arginfo_class_SimpleKafkaClient_Consumer_queryWatermarkOffsets, ZEND_ACC_PUBLIC)
10479
ZEND_FE_END
10580
};

‎package.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@
4242
<file role="src" name="functions.c"/>
4343
<file role="src" name="functions_arginfo.h"/>
4444
<file role="src" name="simple_kafka_client.c"/>
45-
<file role="src" name="kafka_arginfo.h"/>
45+
<file role="src" name="simple_kafka_client_arginfo.h"/>
4646
<file role="src" name="kafka_exception.c"/>
4747
<file role="src" name="kafka_exception_arginfo.h"/>
4848
<file role="src" name="message.c"/>

‎producer.c‎

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -120,6 +120,26 @@ ZEND_METHOD(SimpleKafkaClient_Producer, flush)
120120
}
121121
/* }}} */
122122

123+
/* {{{ proto int SimpleKafkaClient\Producer::poll(int $timeoutMs)
124+
Polls the provided kafka handle for events */
125+
ZEND_METHOD(SimpleKafkaClient_Producer, poll)
126+
{
127+
kafka_object *intern;
128+
zend_long timeout_ms;
129+
130+
ZEND_PARSE_PARAMETERS_START_EX(ZEND_PARSE_PARAMS_THROW, 1, 1)
131+
Z_PARAM_LONG(timeout_ms)
132+
ZEND_PARSE_PARAMETERS_END();
133+
134+
intern = get_kafka_object(getThis());
135+
if (!intern) {
136+
return;
137+
}
138+
139+
RETURN_LONG(rd_kafka_poll(intern->rk, timeout_ms));
140+
}
141+
/* }}} */
142+
123143
/* {{{ proto int SimpleKafkaClient\Producer::purge(int $purge_flags)
124144
Purge messages that are in queue or in flight */
125145
ZEND_METHOD(SimpleKafkaClient_Producer, purge)

‎producer.stub.php‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,8 @@ public function abortTransaction(int $timeoutMs): void {}
1818

1919
public function flush(int $timeoutMs): int {}
2020

21+
public function poll(int $timeoutMs): int {}
22+
2123
public function purge(int $purgeFlags): int {}
2224

2325
public function getTopicHandle(string $topic): ProducerTopic {}

‎producer_arginfo.h‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/* This is a generated file, edit the .stub.php file instead.
2-
* Stub hash: ae03dd8127a9e4799e241bc490de200ff18a4178 */
2+
* Stub hash: 30c864ad8163b67989b699e8e94c4fe6539a5386 */
33

44
ZEND_BEGIN_ARG_INFO_EX(arginfo_class_SimpleKafkaClient_Producer___construct, 0, 0, 1)
55
ZEND_ARG_OBJ_INFO(0, configuration, SimpleKafkaClient\\Configuration, 0)
@@ -20,6 +20,8 @@ ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_class_SimpleKafkaClient_Producer
2020
ZEND_ARG_TYPE_INFO(0, timeoutMs, IS_LONG, 0)
2121
ZEND_END_ARG_INFO()
2222

23+
#define arginfo_class_SimpleKafkaClient_Producer_poll arginfo_class_SimpleKafkaClient_Producer_flush
24+
2325
ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_class_SimpleKafkaClient_Producer_purge, 0, 1, IS_LONG, 0)
2426
ZEND_ARG_TYPE_INFO(0, purgeFlags, IS_LONG, 0)
2527
ZEND_END_ARG_INFO()
@@ -35,6 +37,7 @@ ZEND_METHOD(SimpleKafkaClient_Producer, beginTransaction);
3537
ZEND_METHOD(SimpleKafkaClient_Producer, commitTransaction);
3638
ZEND_METHOD(SimpleKafkaClient_Producer, abortTransaction);
3739
ZEND_METHOD(SimpleKafkaClient_Producer, flush);
40+
ZEND_METHOD(SimpleKafkaClient_Producer, poll);
3841
ZEND_METHOD(SimpleKafkaClient_Producer, purge);
3942
ZEND_METHOD(SimpleKafkaClient_Producer, getTopicHandle);
4043

@@ -46,6 +49,7 @@ static const zend_function_entry class_SimpleKafkaClient_Producer_methods[] = {
4649
ZEND_ME(SimpleKafkaClient_Producer, commitTransaction, arginfo_class_SimpleKafkaClient_Producer_commitTransaction, ZEND_ACC_PUBLIC)
4750
ZEND_ME(SimpleKafkaClient_Producer, abortTransaction, arginfo_class_SimpleKafkaClient_Producer_abortTransaction, ZEND_ACC_PUBLIC)
4851
ZEND_ME(SimpleKafkaClient_Producer, flush, arginfo_class_SimpleKafkaClient_Producer_flush, ZEND_ACC_PUBLIC)
52+
ZEND_ME(SimpleKafkaClient_Producer, poll, arginfo_class_SimpleKafkaClient_Producer_poll, ZEND_ACC_PUBLIC)
4953
ZEND_ME(SimpleKafkaClient_Producer, purge, arginfo_class_SimpleKafkaClient_Producer_purge, ZEND_ACC_PUBLIC)
5054
ZEND_ME(SimpleKafkaClient_Producer, getTopicHandle, arginfo_class_SimpleKafkaClient_Producer_getTopicHandle, ZEND_ACC_PUBLIC)
5155
ZEND_FE_END

‎simple_kafka_client.c‎

Lines changed: 3 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@
4545
#include "consumer_arginfo.h"
4646
#include "functions_arginfo.h"
4747
#include "producer_arginfo.h"
48-
#include "kafka_arginfo.h"
48+
#include "simple_kafka_client_arginfo.h"
4949

5050
enum {
5151
RD_KAFKA_LOG_PRINT = 100
@@ -184,26 +184,6 @@ ZEND_METHOD(SimpleKafkaClient_Kafka, getOutQLen)
184184
}
185185
/* }}} */
186186

187-
/* {{{ proto int SimpleKafkaClient\Kafka::poll(int $timeoutMs)
188-
Polls the provided kafka handle for events */
189-
ZEND_METHOD(SimpleKafkaClient_Kafka, poll)
190-
{
191-
kafka_object *intern;
192-
zend_long timeout_ms;
193-
194-
ZEND_PARSE_PARAMETERS_START_EX(ZEND_PARSE_PARAMS_THROW, 1, 1)
195-
Z_PARAM_LONG(timeout_ms)
196-
ZEND_PARSE_PARAMETERS_END();
197-
198-
intern = get_kafka_object(getThis());
199-
if (!intern) {
200-
return;
201-
}
202-
203-
RETURN_LONG(rd_kafka_poll(intern->rk, timeout_ms));
204-
}
205-
/* }}} */
206-
207187
/* {{{ proto void SimpleKafkaClient\Kafka::queryWatermarkOffsets(string $topic, int $partition, int &$low, int &$high, int $timeout_ms)
208188
Query broker for low (oldest/beginning) or high (newest/end) offsets for partition */
209189
ZEND_METHOD(SimpleKafkaClient_Kafka, queryWatermarkOffsets)
@@ -216,7 +196,7 @@ ZEND_METHOD(SimpleKafkaClient_Kafka, queryWatermarkOffsets)
216196
zval *lowResult, *highResult;
217197
rd_kafka_resp_err_t err;
218198

219-
ZEND_PARSE_PARAMETERS_START_EX(ZEND_PARSE_PARAMS_THROW, 2, 2)
199+
ZEND_PARSE_PARAMETERS_START_EX(ZEND_PARSE_PARAMS_THROW, 5, 5)
220200
Z_PARAM_STRING(topic, topic_length)
221201
Z_PARAM_LONG(partition)
222202
Z_PARAM_ZVAL(lowResult)
@@ -352,7 +332,7 @@ PHP_MINIT_FUNCTION(simple_kafka_client)
352332
ce_kafka_producer = zend_register_internal_class_ex(&ce, ce_kafka);
353333

354334
INIT_NS_CLASS_ENTRY(ce, "SimpleKafkaClient", "Consumer", class_SimpleKafkaClient_Consumer_methods);
355-
ce_kafka_consumer = zend_register_internal_class(&ce);
335+
ce_kafka_consumer = zend_register_internal_class_ex(&ce, ce_kafka);
356336
ce_kafka_consumer->create_object = kafka_new;
357337

358338
kafka_conf_init(INIT_FUNC_ARGS_PASSTHRU);

‎kafka.stub.php‎ renamed to ‎simple_kafka_client.stub.php‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,6 @@ public function getMetadata(bool $allTopics, int $timeoutMs, Topic $topic): Meta
1010

1111
public function getOutQLen(): int {}
1212

13-
public function poll(int $timeoutMs): int {}
14-
1513
public function queryWatermarkOffsets(string $topic, int $partition, int &$low, int &$high, int $timeoutMs): void {}
1614

1715
public function offsetsForTimes(array $topicPartitions, int $timeoutMs): array {}

‎kafka_arginfo.h‎ renamed to ‎simple_kafka_client_arginfo.h‎

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/* This is a generated file, edit the .stub.php file instead.
2-
* Stub hash: 5620609ea29ca05a20736ac8412bee6e4cc39615 */
2+
* Stub hash: e61ec0821ea47152b2ce6b7116ec791c0c712a73 */
33

44
ZEND_BEGIN_ARG_WITH_RETURN_OBJ_INFO_EX(arginfo_class_SimpleKafkaClient_Kafka_getMetadata, 0, 3, SimpleKafkaClient\\Metadata, 0)
55
ZEND_ARG_TYPE_INFO(0, allTopics, _IS_BOOL, 0)
@@ -10,10 +10,6 @@ ZEND_END_ARG_INFO()
1010
ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_class_SimpleKafkaClient_Kafka_getOutQLen, 0, 0, IS_LONG, 0)
1111
ZEND_END_ARG_INFO()
1212

13-
ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_class_SimpleKafkaClient_Kafka_poll, 0, 1, IS_LONG, 0)
14-
ZEND_ARG_TYPE_INFO(0, timeoutMs, IS_LONG, 0)
15-
ZEND_END_ARG_INFO()
16-
1713
ZEND_BEGIN_ARG_WITH_RETURN_TYPE_INFO_EX(arginfo_class_SimpleKafkaClient_Kafka_queryWatermarkOffsets, 0, 5, IS_VOID, 0)
1814
ZEND_ARG_TYPE_INFO(0, topic, IS_STRING, 0)
1915
ZEND_ARG_TYPE_INFO(0, partition, IS_LONG, 0)
@@ -30,15 +26,13 @@ ZEND_END_ARG_INFO()
3026

3127
ZEND_METHOD(SimpleKafkaClient_Kafka, getMetadata);
3228
ZEND_METHOD(SimpleKafkaClient_Kafka, getOutQLen);
33-
ZEND_METHOD(SimpleKafkaClient_Kafka, poll);
3429
ZEND_METHOD(SimpleKafkaClient_Kafka, queryWatermarkOffsets);
3530
ZEND_METHOD(SimpleKafkaClient_Kafka, offsetsForTimes);
3631

3732

3833
static const zend_function_entry class_SimpleKafkaClient_Kafka_methods[] = {
3934
ZEND_ME(SimpleKafkaClient_Kafka, getMetadata, arginfo_class_SimpleKafkaClient_Kafka_getMetadata, ZEND_ACC_PUBLIC)
4035
ZEND_ME(SimpleKafkaClient_Kafka, getOutQLen, arginfo_class_SimpleKafkaClient_Kafka_getOutQLen, ZEND_ACC_PUBLIC)
41-
ZEND_ME(SimpleKafkaClient_Kafka, poll, arginfo_class_SimpleKafkaClient_Kafka_poll, ZEND_ACC_PUBLIC)
4236
ZEND_ME(SimpleKafkaClient_Kafka, queryWatermarkOffsets, arginfo_class_SimpleKafkaClient_Kafka_queryWatermarkOffsets, ZEND_ACC_PUBLIC)
4337
ZEND_ME(SimpleKafkaClient_Kafka, offsetsForTimes, arginfo_class_SimpleKafkaClient_Kafka_offsetsForTimes, ZEND_ACC_PUBLIC)
4438
ZEND_FE_END

0 commit comments

Comments
 (0)