php-rdkafka
php-rdkafka copied to clipboard
Production-ready, stable Kafka client for PHP
* PHP version: 7.4 * librdkafka version: 0.11.6 * php-rdkafka version: * kafka version: When producing a record like this: ```php $topic->produce(RD_KAFKA_PARTITION_UA, 0, json_encode($payload), intval($recordId)); ``` I'd need the key...
Hi! Param `request.required.acks = -1` is not working. I have message in log "Broker: Not enough in-sync replicas". But message has been sent to the server. ``` $conf = new...
* PHP version: 7.1 * librdkafka version: 1.8.2.255 * php-rdkafka version: 5.0 * kafka version: 2 my configuration: ```php
* PHP version: 7.4.23 * librdkafka version: 1.6.0-1 * php-rdkafka version: 5.0.0 * kafka version: 2.8.0 I am running into timeouts when tying to use `php-rdkafka` on an ARM machine...
Hey guys How i can get offset by topic? like: ./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic mytopic1
* PHP version: 7.4 * librdkafka version:1.6.1 * php-rdkafka version: 5.0.0 * kafka version: It seems like the Conf class is missing setter function for librdkafka configuration property `oauthbearer_token_refresh_cb`. This...
when test message_headers.php in centos i got following output: ``` > php message_headers.php 6 messages delivered Got message: message 0 | Headers: none PHP Warning: array_walk() expects parameter 1 to...
There is the possibility to pass along metadata for the offsets to commit. This would be possible if we expose metadata of topic partition and internally set metadata_size accordingly. The...
When dumping `RdKafka\Conf` you only see the global settings. Every `rd_kafka_conf_t` can also have a `rd_kafka_topic_conf_t`, so it might be confusing to not find certain settings in the dump, that...
There was quite some functionality added and it would be nice to check if it would make sense to have some more tests for the newly added functionality. This ticket...