php-pubsub-kafka

php-pubsub-kafka copied to clipboard

This is useful to allow viewing of the message metadata.

LeighBicknell

There is a bug,Not calling flush can lead to message loss. public function publish($channel, $message) { $topic = $this->producer->newTopic($channel); $topic->produce(RD_KAFKA_PARTITION_UA, 0, Utils::serializeMessage($message)); }

Walker-P

Not able to add a key when producing.

1

There isn't an option to add a key to a payload when producing. It seems to be an easy fix so I have created a pull request.[https://github.com/Superbalist/php-pubsub-kafka/pull/5](url)

mark-jones-entanet

Add an optional key parameter to the publish method. This is useful if you need related messages to go on the same partition and if you are using ksql.

mark-jones-entanet

Can't connect to anything other than localhost

7

In summary, I can't connect to a Kafka broker running on a host other than localhost. I can set up a SSH tunnel to tunnel 9092 traffic on the broker...

evictor

Hi, I just want to publish messages from my code, the consumer is another program not in php. Do I still need to create the $consumer object present in all...

Lambik