diff options
| -rw-r--r-- | .gitignore | 9 | ||||
| -rw-r--r-- | Makefile | 4 | ||||
| -rw-r--r-- | PHPINFO | 8 | ||||
| -rw-r--r-- | REFLECTION | 1568 | ||||
| -rw-r--r-- | php-pecl-rdkafka5.spec | 326 |
5 files changed, 1915 insertions, 0 deletions
diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..01f0400 --- /dev/null +++ b/.gitignore @@ -0,0 +1,9 @@ +clog +package-*.xml +*.tgz +*.tar.bz2 +*.tar.gz +*.tar.xz +*.tar.xz.asc +*.src.rpm +*/*rpm diff --git a/Makefile b/Makefile new file mode 100644 index 0000000..13af741 --- /dev/null +++ b/Makefile @@ -0,0 +1,4 @@ +SRCDIR := $(shell pwd) +NAME := $(shell basename $(SRCDIR)) +include ../../../common/Makefile + @@ -0,0 +1,8 @@ + +rdkafka + +rdkafka support => enabled +version => 4.1.2 +build date => Dec 25 2020 00:00:00 +librdkafka version (runtime) => 1.5.3 +librdkafka version (build) => 1.5.3.255 diff --git a/REFLECTION b/REFLECTION new file mode 100644 index 0000000..e66caae --- /dev/null +++ b/REFLECTION @@ -0,0 +1,1568 @@ +Extension [ <persistent> extension #98 rdkafka version 4.1.2 ] { + + - Constants [172] { + Constant [ int RD_KAFKA_CONSUMER ] { 1 } + Constant [ int RD_KAFKA_OFFSET_BEGINNING ] { -2 } + Constant [ int RD_KAFKA_OFFSET_END ] { -1 } + Constant [ int RD_KAFKA_OFFSET_STORED ] { -1000 } + Constant [ int RD_KAFKA_PARTITION_UA ] { -1 } + Constant [ int RD_KAFKA_PRODUCER ] { 0 } + Constant [ int RD_KAFKA_MSG_F_BLOCK ] { 4 } + Constant [ int RD_KAFKA_PURGE_F_QUEUE ] { 1 } + Constant [ int RD_KAFKA_PURGE_F_INFLIGHT ] { 2 } + Constant [ int RD_KAFKA_PURGE_F_NON_BLOCKING ] { 4 } + Constant [ int RD_KAFKA_VERSION ] { 17105919 } + Constant [ int RD_KAFKA_BUILD_VERSION ] { 17105919 } + Constant [ int RD_KAFKA_RESP_ERR__BEGIN ] { -200 } + Constant [ int RD_KAFKA_RESP_ERR__BAD_MSG ] { -199 } + Constant [ int RD_KAFKA_RESP_ERR__BAD_COMPRESSION ] { -198 } + Constant [ int RD_KAFKA_RESP_ERR__DESTROY ] { -197 } + Constant [ int RD_KAFKA_RESP_ERR__FAIL ] { -196 } + Constant [ int RD_KAFKA_RESP_ERR__TRANSPORT ] { -195 } + Constant [ int RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE ] { -194 } + Constant [ int RD_KAFKA_RESP_ERR__RESOLVE ] { -193 } + Constant [ int RD_KAFKA_RESP_ERR__MSG_TIMED_OUT ] { -192 } + Constant [ int RD_KAFKA_RESP_ERR__PARTITION_EOF ] { -191 } + Constant [ int RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION ] { -190 } + Constant [ int RD_KAFKA_RESP_ERR__FS ] { -189 } + Constant [ int RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC ] { -188 } + Constant [ int RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN ] { -187 } + Constant [ int RD_KAFKA_RESP_ERR__INVALID_ARG ] { -186 } + Constant [ int RD_KAFKA_RESP_ERR__TIMED_OUT ] { -185 } + Constant [ int RD_KAFKA_RESP_ERR__QUEUE_FULL ] { -184 } + Constant [ int RD_KAFKA_RESP_ERR__ISR_INSUFF ] { -183 } + Constant [ int RD_KAFKA_RESP_ERR__NODE_UPDATE ] { -182 } + Constant [ int RD_KAFKA_RESP_ERR__SSL ] { -181 } + Constant [ int RD_KAFKA_RESP_ERR__WAIT_COORD ] { -180 } + Constant [ int RD_KAFKA_RESP_ERR__UNKNOWN_GROUP ] { -179 } + Constant [ int RD_KAFKA_RESP_ERR__IN_PROGRESS ] { -178 } + Constant [ int RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS ] { -177 } + Constant [ int RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION ] { -176 } + Constant [ int RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS ] { -175 } + Constant [ int RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS ] { -174 } + Constant [ int RD_KAFKA_RESP_ERR__CONFLICT ] { -173 } + Constant [ int RD_KAFKA_RESP_ERR__STATE ] { -172 } + Constant [ int RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL ] { -171 } + Constant [ int RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED ] { -170 } + Constant [ int RD_KAFKA_RESP_ERR__AUTHENTICATION ] { -169 } + Constant [ int RD_KAFKA_RESP_ERR__NO_OFFSET ] { -168 } + Constant [ int RD_KAFKA_RESP_ERR__OUTDATED ] { -167 } + Constant [ int RD_KAFKA_RESP_ERR__TIMED_OUT_QUEUE ] { -166 } + Constant [ int RD_KAFKA_RESP_ERR__UNSUPPORTED_FEATURE ] { -165 } + Constant [ int RD_KAFKA_RESP_ERR__WAIT_CACHE ] { -164 } + Constant [ int RD_KAFKA_RESP_ERR__INTR ] { -163 } + Constant [ int RD_KAFKA_RESP_ERR__KEY_SERIALIZATION ] { -162 } + Constant [ int RD_KAFKA_RESP_ERR__VALUE_SERIALIZATION ] { -161 } + Constant [ int RD_KAFKA_RESP_ERR__KEY_DESERIALIZATION ] { -160 } + Constant [ int RD_KAFKA_RESP_ERR__VALUE_DESERIALIZATION ] { -159 } + Constant [ int RD_KAFKA_RESP_ERR__PARTIAL ] { -158 } + Constant [ int RD_KAFKA_RESP_ERR__READ_ONLY ] { -157 } + Constant [ int RD_KAFKA_RESP_ERR__NOENT ] { -156 } + Constant [ int RD_KAFKA_RESP_ERR__UNDERFLOW ] { -155 } + Constant [ int RD_KAFKA_RESP_ERR__INVALID_TYPE ] { -154 } + Constant [ int RD_KAFKA_RESP_ERR__RETRY ] { -153 } + Constant [ int RD_KAFKA_RESP_ERR__PURGE_QUEUE ] { -152 } + Constant [ int RD_KAFKA_RESP_ERR__PURGE_INFLIGHT ] { -151 } + Constant [ int RD_KAFKA_RESP_ERR__FATAL ] { -150 } + Constant [ int RD_KAFKA_RESP_ERR__INCONSISTENT ] { -149 } + Constant [ int RD_KAFKA_RESP_ERR__GAPLESS_GUARANTEE ] { -148 } + Constant [ int RD_KAFKA_RESP_ERR__MAX_POLL_EXCEEDED ] { -147 } + Constant [ int RD_KAFKA_RESP_ERR__UNKNOWN_BROKER ] { -146 } + Constant [ int RD_KAFKA_RESP_ERR__NOT_CONFIGURED ] { -145 } + Constant [ int RD_KAFKA_RESP_ERR__FENCED ] { -144 } + Constant [ int RD_KAFKA_RESP_ERR__APPLICATION ] { -143 } + Constant [ int RD_KAFKA_RESP_ERR__END ] { -100 } + Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN ] { -1 } + Constant [ int RD_KAFKA_RESP_ERR_NO_ERROR ] { 0 } + Constant [ int RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE ] { 1 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_MSG ] { 2 } + Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART ] { 3 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE ] { 4 } + Constant [ int RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE ] { 5 } + Constant [ int RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION ] { 6 } + Constant [ int RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT ] { 7 } + Constant [ int RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE ] { 8 } + Constant [ int RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE ] { 9 } + Constant [ int RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE ] { 10 } + Constant [ int RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH ] { 11 } + Constant [ int RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE ] { 12 } + Constant [ int RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION ] { 13 } + Constant [ int RD_KAFKA_RESP_ERR_COORDINATOR_LOAD_IN_PROGRESS ] { 14 } + Constant [ int RD_KAFKA_RESP_ERR_COORDINATOR_NOT_AVAILABLE ] { 15 } + Constant [ int RD_KAFKA_RESP_ERR_NOT_COORDINATOR ] { 16 } + Constant [ int RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION ] { 17 } + Constant [ int RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE ] { 18 } + Constant [ int RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS ] { 19 } + Constant [ int RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND ] { 20 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS ] { 21 } + Constant [ int RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION ] { 22 } + Constant [ int RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL ] { 23 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_GROUP_ID ] { 24 } + Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID ] { 25 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT ] { 26 } + Constant [ int RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS ] { 27 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE ] { 28 } + Constant [ int RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED ] { 29 } + Constant [ int RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED ] { 30 } + Constant [ int RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED ] { 31 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP ] { 32 } + Constant [ int RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM ] { 33 } + Constant [ int RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE ] { 34 } + Constant [ int RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION ] { 35 } + Constant [ int RD_KAFKA_RESP_ERR_TOPIC_ALREADY_EXISTS ] { 36 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_PARTITIONS ] { 37 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_REPLICATION_FACTOR ] { 38 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_REPLICA_ASSIGNMENT ] { 39 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_CONFIG ] { 40 } + Constant [ int RD_KAFKA_RESP_ERR_NOT_CONTROLLER ] { 41 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_REQUEST ] { 42 } + Constant [ int RD_KAFKA_RESP_ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT ] { 43 } + Constant [ int RD_KAFKA_RESP_ERR_POLICY_VIOLATION ] { 44 } + Constant [ int RD_KAFKA_RESP_ERR_OUT_OF_ORDER_SEQUENCE_NUMBER ] { 45 } + Constant [ int RD_KAFKA_RESP_ERR_DUPLICATE_SEQUENCE_NUMBER ] { 46 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_PRODUCER_EPOCH ] { 47 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_TXN_STATE ] { 48 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_PRODUCER_ID_MAPPING ] { 49 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_TRANSACTION_TIMEOUT ] { 50 } + Constant [ int RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS ] { 51 } + Constant [ int RD_KAFKA_RESP_ERR_TRANSACTION_COORDINATOR_FENCED ] { 52 } + Constant [ int RD_KAFKA_RESP_ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED ] { 53 } + Constant [ int RD_KAFKA_RESP_ERR_SECURITY_DISABLED ] { 54 } + Constant [ int RD_KAFKA_RESP_ERR_OPERATION_NOT_ATTEMPTED ] { 55 } + Constant [ int RD_KAFKA_RESP_ERR_KAFKA_STORAGE_ERROR ] { 56 } + Constant [ int RD_KAFKA_RESP_ERR_LOG_DIR_NOT_FOUND ] { 57 } + Constant [ int RD_KAFKA_RESP_ERR_SASL_AUTHENTICATION_FAILED ] { 58 } + Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_PRODUCER_ID ] { 59 } + Constant [ int RD_KAFKA_RESP_ERR_REASSIGNMENT_IN_PROGRESS ] { 60 } + Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTH_DISABLED ] { 61 } + Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_NOT_FOUND ] { 62 } + Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_OWNER_MISMATCH ] { 63 } + Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_REQUEST_NOT_ALLOWED ] { 64 } + Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTHORIZATION_FAILED ] { 65 } + Constant [ int RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_EXPIRED ] { 66 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_PRINCIPAL_TYPE ] { 67 } + Constant [ int RD_KAFKA_RESP_ERR_NON_EMPTY_GROUP ] { 68 } + Constant [ int RD_KAFKA_RESP_ERR_GROUP_ID_NOT_FOUND ] { 69 } + Constant [ int RD_KAFKA_RESP_ERR_FETCH_SESSION_ID_NOT_FOUND ] { 70 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_FETCH_SESSION_EPOCH ] { 71 } + Constant [ int RD_KAFKA_RESP_ERR_LISTENER_NOT_FOUND ] { 72 } + Constant [ int RD_KAFKA_RESP_ERR_TOPIC_DELETION_DISABLED ] { 73 } + Constant [ int RD_KAFKA_RESP_ERR_FENCED_LEADER_EPOCH ] { 74 } + Constant [ int RD_KAFKA_RESP_ERR_UNKNOWN_LEADER_EPOCH ] { 75 } + Constant [ int RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE ] { 76 } + Constant [ int RD_KAFKA_RESP_ERR_STALE_BROKER_EPOCH ] { 77 } + Constant [ int RD_KAFKA_RESP_ERR_OFFSET_NOT_AVAILABLE ] { 78 } + Constant [ int RD_KAFKA_RESP_ERR_MEMBER_ID_REQUIRED ] { 79 } + Constant [ int RD_KAFKA_RESP_ERR_PREFERRED_LEADER_NOT_AVAILABLE ] { 80 } + Constant [ int RD_KAFKA_RESP_ERR_GROUP_MAX_SIZE_REACHED ] { 81 } + Constant [ int RD_KAFKA_RESP_ERR_FENCED_INSTANCE_ID ] { 82 } + Constant [ int RD_KAFKA_RESP_ERR_ELIGIBLE_LEADERS_NOT_AVAILABLE ] { 83 } + Constant [ int RD_KAFKA_RESP_ERR_ELECTION_NOT_NEEDED ] { 84 } + Constant [ int RD_KAFKA_RESP_ERR_NO_REASSIGNMENT_IN_PROGRESS ] { 85 } + Constant [ int RD_KAFKA_RESP_ERR_GROUP_SUBSCRIBED_TO_TOPIC ] { 86 } + Constant [ int RD_KAFKA_RESP_ERR_INVALID_RECORD ] { 87 } + Constant [ int RD_KAFKA_RESP_ERR_UNSTABLE_OFFSET_COMMIT ] { 88 } + Constant [ int RD_KAFKA_CONF_UNKNOWN ] { -2 } + Constant [ int RD_KAFKA_CONF_INVALID ] { -1 } + Constant [ int RD_KAFKA_CONF_OK ] { 0 } + Constant [ int RD_KAFKA_MSG_PARTITIONER_RANDOM ] { 2 } + Constant [ int RD_KAFKA_MSG_PARTITIONER_CONSISTENT ] { 3 } + Constant [ int RD_KAFKA_MSG_PARTITIONER_CONSISTENT_RANDOM ] { 4 } + Constant [ int RD_KAFKA_MSG_PARTITIONER_MURMUR2 ] { 5 } + Constant [ int RD_KAFKA_MSG_PARTITIONER_MURMUR2_RANDOM ] { 6 } + Constant [ int RD_KAFKA_LOG_PRINT ] { 100 } + Constant [ int RD_KAFKA_LOG_SYSLOG ] { 101 } + Constant [ int RD_KAFKA_LOG_SYSLOG_PRINT ] { 102 } + } + + - Functions { + Function [ <internal:rdkafka> function rd_kafka_get_err_descs ] { + + - Parameters [0] { + } + } + Function [ <internal:rdkafka> function rd_kafka_err2str ] { + + - Parameters [1] { + Parameter #0 [ <required> $err ] + } + } + Function [ <internal, deprecated:rdkafka> function rd_kafka_errno2err ] { + + - Parameters [1] { + Parameter #0 [ <required> $errnox ] + } + } + Function [ <internal, deprecated:rdkafka> function rd_kafka_errno ] { + + - Parameters [0] { + } + } + Function [ <internal:rdkafka> function rd_kafka_offset_tail ] { + + - Parameters [1] { + Parameter #0 [ <required> $cnt ] + } + } + Function [ <internal:rdkafka> function rd_kafka_thread_cnt ] { + + - Parameters [0] { + } + } + } + + - Classes [20] { + Class [ <internal:rdkafka> abstract class RdKafka ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [2] { + Property [ <default> private $error_cb ] + Property [ <default> private $dr_cb ] + } + + - Methods [13] { + Method [ <internal:rdkafka> public method addBrokers ] { + + - Parameters [1] { + Parameter #0 [ <required> $broker_list ] + } + } + + 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 ] + Parameter #1 [ <optional> $only_topic ] + Parameter #2 [ <optional> $timeout_ms ] + } + } + + Method [ <internal, deprecated:rdkafka> public method setLogLevel ] { + + - Parameters [1] { + Parameter #0 [ <required> $level ] + } + } + + Method [ <internal:rdkafka> public method newTopic ] { + + - Parameters [2] { + Parameter #0 [ <required> $topic_name ] + Parameter #1 [ <optional> $topic_conf ] + } + } + + Method [ <internal, deprecated:rdkafka> public method outqLen ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method poll ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + + 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 ] + } + } + + 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 ] + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\Consumer extends RdKafka ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [15] { + Method [ <internal:rdkafka, ctor> public method __construct ] { + + - Parameters [1] { + Parameter #0 [ <optional> $conf ] + } + } + + Method [ <internal:rdkafka> public method newQueue ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] { + + - Parameters [1] { + Parameter #0 [ <required> $broker_list ] + } + } + + 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 ] + Parameter #1 [ <optional> $only_topic ] + Parameter #2 [ <optional> $timeout_ms ] + } + } + + Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] { + + - Parameters [1] { + Parameter #0 [ <required> $level ] + } + } + + Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] { + + - Parameters [2] { + Parameter #0 [ <required> $topic_name ] + Parameter #1 [ <optional> $topic_conf ] + } + } + + Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method outqLen ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka, inherits RdKafka> public method poll ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + + 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 ] + } + } + + Method [ <internal:rdkafka, inherits 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, inherits RdKafka> public method offsetsForTimes ] { + + - Parameters [2] { + Parameter #0 [ <required> $topic_partitions ] + Parameter #1 [ <required> $timeout_ms ] + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\Producer extends RdKafka ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [18] { + Method [ <internal:rdkafka, ctor> public method __construct ] { + + - Parameters [1] { + Parameter #0 [ <optional> $conf ] + } + } + + Method [ <internal:rdkafka> public method initTransactions ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + + Method [ <internal:rdkafka> public method beginTransaction ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method commitTransaction ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + + Method [ <internal:rdkafka> public method abortTransaction ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + + Method [ <internal:rdkafka, inherits RdKafka> public method addBrokers ] { + + - Parameters [1] { + Parameter #0 [ <required> $broker_list ] + } + } + + 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 ] + Parameter #1 [ <optional> $only_topic ] + Parameter #2 [ <optional> $timeout_ms ] + } + } + + Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method setLogLevel ] { + + - Parameters [1] { + Parameter #0 [ <required> $level ] + } + } + + Method [ <internal:rdkafka, inherits RdKafka> public method newTopic ] { + + - Parameters [2] { + Parameter #0 [ <required> $topic_name ] + Parameter #1 [ <optional> $topic_conf ] + } + } + + Method [ <internal, deprecated:rdkafka, inherits RdKafka> public method outqLen ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka, inherits RdKafka> public method poll ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + + 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 ] + } + } + + Method [ <internal:rdkafka, inherits 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, inherits RdKafka> public method offsetsForTimes ] { + + - Parameters [2] { + Parameter #0 [ <required> $topic_partitions ] + Parameter #1 [ <required> $timeout_ms ] + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\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:rdkafka> class RdKafka\Conf ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [11] { + Method [ <internal:rdkafka, ctor> public method __construct ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method dump ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method set ] { + + - Parameters [2] { + Parameter #0 [ <required> $name ] + Parameter #1 [ <required> $value ] + } + } + + Method [ <internal, deprecated:rdkafka> public method setDefaultTopicConf ] { + + - Parameters [1] { + Parameter #0 [ <required> $topic_conf ] + } + } + + Method [ <internal:rdkafka> public method setErrorCb ] { + + - Parameters [1] { + Parameter #0 [ <required> $callback ] + } + } + + Method [ <internal:rdkafka> public method setDrMsgCb ] { + + - Parameters [1] { + Parameter #0 [ <required> $callback ] + } + } + + Method [ <internal:rdkafka> public method setStatsCb ] { + + - Parameters [1] { + Parameter #0 [ <required> $callback ] + } + } + + Method [ <internal:rdkafka> public method setRebalanceCb ] { + + - Parameters [1] { + Parameter #0 [ <required> $callback ] + } + } + + Method [ <internal:rdkafka> public method setConsumeCb ] { + + - Parameters [1] { + Parameter #0 [ <required> $callback ] + } + } + + Method [ <internal:rdkafka> public method setOffsetCommitCb ] { + + - Parameters [1] { + Parameter #0 [ <required> $callback ] + } + } + + Method [ <internal:rdkafka> public method setLogCb ] { + + - Parameters [1] { + Parameter #0 [ <required> $callback ] + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\TopicConf ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [4] { + Method [ <internal:rdkafka, ctor> public method __construct ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method dump ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method set ] { + + - Parameters [2] { + Parameter #0 [ <required> $name ] + Parameter #1 [ <required> $value ] + } + } + + Method [ <internal:rdkafka> public method setPartitioner ] { + + - Parameters [1] { + Parameter #0 [ <required> $partitioner ] + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\KafkaErrorException extends RdKafka\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:rdkafka, overwrites Exception, ctor> public method __construct ] { + + - Parameters [6] { + Parameter #0 [ <required> $message ] + Parameter #1 [ <required> $code ] + Parameter #2 [ <required> $error_string ] + Parameter #3 [ <required> $isFatal ] + Parameter #4 [ <required> $isRetriable ] + Parameter #5 [ <required> $transactionRequiresAbort ] + } + } + + Method [ <internal:rdkafka> public method getErrorString ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method isFatal ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method isRetriable ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method transactionRequiresAbort ] { + + - Parameters [0] { + } + } + + 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:rdkafka> class RdKafka\KafkaConsumer ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [3] { + Property [ <default> private $error_cb ] + Property [ <default> private $rebalance_cb ] + Property [ <default> private $dr_msg_cb ] + } + + - Methods [16] { + 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] { + } + } + + Method [ <internal:rdkafka> public method commit ] { + + - Parameters [1] { + Parameter #0 [ <optional> $message_or_offsets ] + } + } + + Method [ <internal:rdkafka> public method close ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method commitAsync ] { + + - Parameters [1] { + Parameter #0 [ <optional> $message_or_offsets ] + } + } + + Method [ <internal:rdkafka> public method consume ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + + Method [ <internal:rdkafka> public method subscribe ] { + + - Parameters [1] { + Parameter #0 [ <required> $topics ] + } + } + + Method [ <internal:rdkafka> public method getSubscription ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method unsubscribe ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method getMetadata ] { + + - Parameters [3] { + Parameter #0 [ <required> $all_topics ] + Parameter #1 [ <required> $only_topic ] + Parameter #2 [ <required> $timeout_ms ] + } + } + + Method [ <internal:rdkafka> public method newTopic ] { + + - Parameters [2] { + Parameter #0 [ <required> $topic_name ] + Parameter #1 [ <optional> $topic_conf ] + } + } + + Method [ <internal:rdkafka> public method getCommittedOffsets ] { + + - Parameters [2] { + Parameter #0 [ <required> $topic_partitions ] + 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 ] + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\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:rdkafka> public method errstr ] { + + - Parameters [0] { + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\Metadata ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [4] { + Method [ <internal:rdkafka> public method getOrigBrokerId ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method getOrigBrokerName ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method getBrokers ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method getTopics ] { + + - Parameters [0] { + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\Metadata\Topic ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - 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] { + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\Metadata\Broker ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [3] { + Method [ <internal:rdkafka> public method getId ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method getHost ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method getPort ] { + + - Parameters [0] { + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\Metadata\Partition ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [5] { + Method [ <internal:rdkafka> public method getId ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method getErr ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method getLeader ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method getReplicas ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method getIsrs ] { + + - Parameters [0] { + } + } + } + } + + Class [ <internal:rdkafka> <iterateable> class RdKafka\Metadata\Collection implements Countable, Iterator, Traversable ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [6] { + Method [ <internal:rdkafka, prototype Countable> public method count ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka, prototype Iterator> public method current ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka, prototype Iterator> public method key ] { + + - Parameters [0] { + } + } + + 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] { + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\TopicPartition ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [7] { + Method [ <internal:rdkafka, ctor> public method __construct ] { + + - Parameters [3] { + Parameter #0 [ <required> $topic ] + Parameter #1 [ <required> $partition ] + Parameter #2 [ <optional> $offset ] + } + } + + Method [ <internal:rdkafka> public method getTopic ] { + + - Parameters [0] { + } + } + + 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 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\Queue ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [2] { + Method [ <internal:rdkafka, ctor> private method __construct ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method consume ] { + + - Parameters [1] { + Parameter #0 [ <required> $timeout_ms ] + } + } + } + } + + 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] { + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\ConsumerTopic extends RdKafka\Topic ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [9] { + Method [ <internal:rdkafka, ctor> private method __construct ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method consumeQueueStart ] { + + - Parameters [3] { + Parameter #0 [ <required> $partition ] + Parameter #1 [ <required> $offset ] + Parameter #2 [ <required> $queue ] + } + } + + Method [ <internal:rdkafka> public method consumeCallback ] { + + - Parameters [3] { + Parameter #0 [ <required> $partition ] + Parameter #1 [ <required> $timeout_ms ] + Parameter #2 [ <required> $callback ] + } + } + + Method [ <internal:rdkafka> public method consumeStart ] { + + - Parameters [2] { + Parameter #0 [ <required> $partition ] + Parameter #1 [ <required> $offset ] + } + } + + Method [ <internal:rdkafka> public method consumeStop ] { + + - Parameters [1] { + Parameter #0 [ <required> $partition ] + } + } + + Method [ <internal:rdkafka> public method consume ] { + + - Parameters [2] { + Parameter #0 [ <required> $partition ] + Parameter #1 [ <required> $timeout_ms ] + } + } + + 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] { + Parameter #0 [ <required> $partition ] + Parameter #1 [ <required> $offset ] + } + } + + Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] { + + - Parameters [0] { + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\KafkaConsumerTopic 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> public method offsetStore ] { + + - Parameters [2] { + Parameter #0 [ <required> $partition ] + Parameter #1 [ <required> $offset ] + } + } + + Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] { + + - Parameters [0] { + } + } + } + } + + Class [ <internal:rdkafka> class RdKafka\ProducerTopic extends RdKafka\Topic ] { + + - Constants [0] { + } + + - Static properties [0] { + } + + - Static methods [0] { + } + + - Properties [0] { + } + + - Methods [4] { + Method [ <internal:rdkafka, ctor> private method __construct ] { + + - Parameters [0] { + } + } + + Method [ <internal:rdkafka> public method produce ] { + + - Parameters [4] { + Parameter #0 [ <required> $partition ] + Parameter #1 [ <required> $msgflags ] + Parameter #2 [ <optional> $payload ] + Parameter #3 [ <optional> $key ] + } + } + + Method [ <internal:rdkafka> public method producev ] { + + - Parameters [6] { + Parameter #0 [ <required> $partition ] + Parameter #1 [ <required> $msgflags ] + Parameter #2 [ <optional> $payload ] + Parameter #3 [ <optional> $key ] + Parameter #4 [ <optional> $headers ] + Parameter #5 [ <optional> $timestamp_ms ] + } + } + + Method [ <internal:rdkafka, inherits RdKafka\Topic> public method getName ] { + + - Parameters [0] { + } + } + } + } + } +} + diff --git a/php-pecl-rdkafka5.spec b/php-pecl-rdkafka5.spec new file mode 100644 index 0000000..9a04f52 --- /dev/null +++ b/php-pecl-rdkafka5.spec @@ -0,0 +1,326 @@ +# remirepo/fedora spec file for php-pecl-rdkafka4 +# +# Copyright (c) 2015-2021 Remi Collet +# License: CC-BY-SA +# http://creativecommons.org/licenses/by-sa/4.0/ +# +# Please, preserve the changelog entries +# +%if 0%{?scl:1} +%global sub_prefix %{scl_prefix} +%scl_package php-pecl-rdkafka +%endif + +%global with_zts 0%{!?_without_zts:%{?__ztsphp:1}} +%global pecl_name rdkafka +%global with_tests %{?_without_tests:0}%{!?_without_tests:1} +%global ini_name 40-%{pecl_name}.ini + +%global buildver %(pkg-config --silence-errors --modversion rdkafka 2>/dev/null || echo 65536) + +Summary: Kafka client based on librdkafka +Name: %{?sub_prefix}php-pecl-%{pecl_name}4 +Version: 4.1.2 +Release: 1%{?dist}%{!?nophptag:%(%{__php} -r 'echo ".".PHP_MAJOR_VERSION.".".PHP_MINOR_VERSION;')} +License: MIT +URL: https://pecl.php.net/package/%{pecl_name} +Source0: https://pecl.php.net/get/%{pecl_name}-%{version}.tgz + +# git checkout master; git diff 4.1.2 -- *h *.c tests/ >/tmp/pp +# + cleanup (version, produce_consume_transactional.phpt) +Patch0: %{pecl_name}-php8.patch + +BuildRequires: %{?dtsprefix}gcc +BuildRequires: make +BuildRequires: librdkafka1php-devel +BuildRequires: %{?scl_prefix}php-devel >= 5.6 +BuildRequires: %{?scl_prefix}php-pear + +Requires: %{?scl_prefix}php(zend-abi) = %{php_zend_api} +Requires: %{?scl_prefix}php(api) = %{php_core_api} +%{?_sclreq:Requires: %{?scl_prefix}runtime%{?_sclreq}%{?_isa}} +Requires: librdkafka1php%{?_isa} >= %{buildver} + +Provides: %{?scl_prefix}php-%{pecl_name} = %{version} +Provides: %{?scl_prefix}php-%{pecl_name}%{?_isa} = %{version} +Provides: %{?scl_prefix}php-pecl(%{pecl_name}) = %{version} +Provides: %{?scl_prefix}php-pecl(%{pecl_name})%{?_isa} = %{version} +%if "%{?scl_prefix}" != "%{?sub_prefix}" +Provides: %{?scl_prefix}php-pecl-%{pecl_name} = %{version}-%{release} +Provides: %{?scl_prefix}php-pecl-%{pecl_name}%{?_isa} = %{version}-%{release} +%endif + +%if 0%{?fedora} >= 31 || 0%{?rhel} >= 9 || "%{php_version}" > "7.4" +Obsoletes: %{?scl_prefix}php-pecl-%{pecl_name} < 4 +Provides: %{?scl_prefix}php-pecl-%{pecl_name} = %{version}-%{release} +Provides: %{?scl_prefix}php-pecl-%{pecl_name}%{?_isa} = %{version}-%{release} +%else +# A single version can be installed +Conflicts: %{?scl_prefix}php-pecl-%{pecl_name} < 4 +%endif + +%if "%{?packager}" == "Remi Collet" && 0%{!?scl:1} && 0%{?rhel} +# Other third party repo stuff +%if "%{php_version}" > "7.3" +Obsoletes: php73-pecl-%{pecl_name} <= %{version} +%endif +%if "%{php_version}" > "7.4" +Obsoletes: php74-pecl-%{pecl_name} <= %{version} +%endif +%if "%{php_version}" > "8.0" +Obsoletes: php80-pecl-%{pecl_name} <= %{version} +%endif +%endif + + +%description +This extension is a librdkafka binding providing a working client for Kafka. + +Package built for PHP %(%{__php} -r 'echo PHP_MAJOR_VERSION.".".PHP_MINOR_VERSION;')%{?scl: as Software Collection (%{scl} by %{?scl_vendor}%{!?scl_vendor:rh})}. + + +%prep +%setup -q -c +mv %{pecl_name}-%{version} NTS + +# Don't install tests +sed -e 's/role="test"/role="src"/' \ + %{?_licensedir:-e '/LICENSE/s/role="doc"/role="src"/' } \ + -i package.xml + +cd NTS +%if "%{php_version}" > "8.0" +%patch0 -p1 -b .up +%endif + +# Sanity check, really often broken +extver=$(sed -n '/#define PHP_RDKAFKA_VERSION/{s/.* "//;s/".*$//;p}' php_rdkafka.h) +if test "x${extver}" != "x%{version}"; then + : Error: Upstream extension version is ${extver}, expecting %{version}. + exit 1 +fi +cd .. + +%if %{with_zts} +# Duplicate source tree for NTS / ZTS build +cp -pr NTS ZTS +%endif + +# Create configuration file +cat > %{ini_name} << 'EOF' +; Enable %{pecl_name} extension module +extension=%{pecl_name}.so +EOF + + +%build +%{?dtsenable} + +cd NTS +%{_bindir}/phpize +%configure \ + --with-php-config=%{_bindir}/php-config \ + --with-rdkafka +make %{?_smp_mflags} + +%if %{with_zts} +cd ../ZTS +%{_bindir}/zts-phpize +%configure \ + --with-php-config=%{_bindir}/zts-php-config \ + --with-rdkafka +make %{?_smp_mflags} +%endif + + +%install +%{?dtsenable} + +make -C NTS install INSTALL_ROOT=%{buildroot} + +# install config file +install -D -m 644 %{ini_name} %{buildroot}%{php_inidir}/%{ini_name} + +# Install XML package description +install -D -m 644 package.xml %{buildroot}%{pecl_xmldir}/%{name}.xml + +%if %{with_zts} +make -C ZTS install INSTALL_ROOT=%{buildroot} + +install -D -m 644 %{ini_name} %{buildroot}%{php_ztsinidir}/%{ini_name} +%endif + +# Documentation +for i in $(grep 'role="doc"' package.xml | sed -e 's/^.*name="//;s/".*$//') +do install -Dpm 644 NTS/$i %{buildroot}%{pecl_docdir}/%{pecl_name}/$i +done + + +%if 0%{?fedora} < 24 && 0%{?rhel} < 8 +# when pear installed alone, after us +%triggerin -- %{?scl_prefix}php-pear +if [ -x %{__pecl} ] ; then + %{pecl_install} %{pecl_xmldir}/%{name}.xml >/dev/null || : +fi + +# posttrans as pear can be installed after us +%posttrans +if [ -x %{__pecl} ] ; then + %{pecl_install} %{pecl_xmldir}/%{name}.xml >/dev/null || : +fi + +%postun +if [ $1 -eq 0 -a -x %{__pecl} ] ; then + %{pecl_uninstall} %{pecl_name} >/dev/null || : +fi +%endif + + +%check +cd NTS +: Minimal load test for NTS extension +%{__php} --no-php-ini \ + --define extension=%{buildroot}%{php_extdir}/%{pecl_name}.so \ + --modules | grep '^%{pecl_name}$' + +%if %{with_zts} +cd ../ZTS +: Minimal load test for ZTS extension +%{__ztsphp} --no-php-ini \ + --define extension=%{buildroot}%{php_ztsextdir}/%{pecl_name}.so \ + --modules | grep '^%{pecl_name}$' +%endif + + +%files +%{?_licensedir:%license NTS/LICENSE} +%doc %{pecl_docdir}/%{pecl_name} +%{pecl_xmldir}/%{name}.xml + +%config(noreplace) %{php_inidir}/%{ini_name} +%{php_extdir}/%{pecl_name}.so + +%if %{with_zts} +%config(noreplace) %{php_ztsinidir}/%{ini_name} +%{php_ztsextdir}/%{pecl_name}.so +%endif + + +%changelog +* Fri Dec 25 2020 Remi Collet <remi@remirepo.net> - 4.1.2-1 +- update to 4.1.2 + +* Tue Dec 8 2020 Remi Collet <remi@remirepo.net> - 4.1.1-1 +- update to 4.1.1 + +* Mon Dec 7 2020 Remi Collet <remi@remirepo.net> - 4.1.0-2 +- add upstream patches for PHP 8 + +* Mon Dec 7 2020 Remi Collet <remi@remirepo.net> - 4.1.0-1 +- update to 4.1.0 + +* Thu Oct 8 2020 Remi Collet <remi@remirepo.net> - 4.0.4-1 +- update to 4.0.4 + +* Sun Jun 21 2020 Remi Collet <remi@remirepo.net> - 4.0.3-2 +- rebuild using librdkafka1php 1.4.4 + +* Fri Feb 7 2020 Remi Collet <remi@remirepo.net> - 4.0.3-1 +- update to 4.0.3 + +* Mon Dec 16 2019 Remi Collet <remi@remirepo.net> - 4.0.2-1 +- update to 4.0.2 + +* Mon Dec 9 2019 Remi Collet <remi@remirepo.net> - 4.0.1-1 +- update to 4.0.1 + +* Sat Oct 5 2019 Remi Collet <remi@remirepo.net> - 4.0.0-1 +- update to 4.0.0 +- rename to php-pecl-rdkafka4 +- raise dependency on librdkafka 0.11 + +* Tue Sep 03 2019 Remi Collet <remi@remirepo.net> - 3.1.2-2 +- rebuild for 7.4.0RC1 + +* Tue Jul 9 2019 Remi Collet <remi@remirepo.net> - 3.1.2-1 +- update to 3.1.2 + +* Mon Jul 8 2019 Remi Collet <remi@remirepo.net> - 3.1.1-2 +- add upstream patch to fix PHP 5.6 build + +* Wed Jul 3 2019 Remi Collet <remi@remirepo.net> - 3.1.1-1 +- update to 3.1.1 +- open https://github.com/arnaud-lb/php-rdkafka/issues/235 + broken build with PHP 5.6 (ZVAL_DEREF) + +* Tue Jun 25 2019 Remi Collet <remi@remirepo.net> - 3.1.0-2 +- rebuild with librdkafka 0.11 in EL-8 + +* Thu Apr 18 2019 Remi Collet <remi@remirepo.net> - 3.1.0-1 +- update to 3.1.0 +- raise dependency on PHP 5.6 + +* Thu Aug 16 2018 Remi Collet <remi@remirepo.net> - 3.0.5-3 +- rebuild for 7.3.0beta2 new ABI + +* Wed Jul 18 2018 Remi Collet <remi@remirepo.net> - 3.0.5-2 +- rebuild for 7.3.0alpha4 new ABI + +* Mon Nov 20 2017 Remi Collet <remi@remirepo.net> - 3.0.5-1 +- Update to 3.0.5 + +* Wed Aug 23 2017 Remi Collet <remi@remirepo.net> - 3.0.4-2 +- EL-7 rebuild using librdkafka in EPEL + +* Wed Aug 16 2017 Remi Collet <remi@remirepo.net> - 3.0.4-1 +- Update to 3.0.4 + +* Tue Jul 18 2017 Remi Collet <remi@remirepo.net> - 3.0.3-4 +- rebuild for PHP 7.2.0beta1 new API + +* Wed Jun 21 2017 Remi Collet <remi@remirepo.net> - 3.0.3-2 +- rebuild for 7.2.0alpha2 + +* Mon May 29 2017 Remi Collet <remi@remirepo.net> - 3.0.3-1 +- Update to 3.0.3 + +* Wed May 24 2017 Remi Collet <remi@remirepo.net> - 3.0.2-1 +- Update to 3.0.2 (stable) + +* Sat Jan 28 2017 Remi Collet <remi@fedoraproject.org> - 3.0.1-1 +- Update to 3.0.1 + +* Mon Dec 19 2016 Remi Collet <remi@fedoraproject.org> - 3.0.0-1 +- update to 3.0.0 (php 5 and 7, stable) +- open https://github.com/arnaud-lb/php-rdkafka/issues/98 failed build + fixed by https://github.com/arnaud-lb/php-rdkafka/pull/99 + +* Thu Dec 1 2016 Remi Collet <remi@fedoraproject.org> - 2.0.1-2 +- rebuild with PHP 7.1.0 GA + +* Mon Nov 28 2016 Remi Collet <remi@fedoraproject.org> - 2.0.1-1 +- Update to 2.0.1 + +* Wed Sep 14 2016 Remi Collet <remi@fedoraproject.org> - 2.0.0-2 +- rebuild for PHP 7.1 new API version + +* Fri Sep 09 2016 Remi Collet <remi@fedoraproject.org> - 2.0.0-1 +- Update to 2.0.0 (php 7) +- open https://github.com/arnaud-lb/php-rdkafka/issues/71 + +* Fri Sep 09 2016 Remi Collet <remi@fedoraproject.org> - 1.0.0-1 +- Update to 1.0.0 (php 5) + +* Tue Mar 8 2016 Remi Collet <remi@fedoraproject.org> - 0.9.1-2 +- adapt for F24 + +* Mon Jan 11 2016 Remi Collet <remi@fedoraproject.org> - 0.9.1-1 +- Update to 0.9.1 (beta) + +* Sat Jan 09 2016 Remi Collet <remi@fedoraproject.org> - 0.9.0-1 +- Update to 0.9.0 (beta) + +* Thu May 14 2015 Remi Collet <remi@fedoraproject.org> - 0.0.2-1 +- initial package, version 0.0.2 (alpha) +- open https://github.com/arnaud-lb/php-rdkafka/pull/5 - ZTS build +- open https://github.com/arnaud-lb/php-rdkafka/pull/4 - License |