I have one topic with a dynamic number of sections (for example: from 1 to 100). This implementation was chosen for a number of reasons.
The number of users of the topic is also dynamic. So it is necessary for concurrency.
Unfortunately, I could not understand how to properly configure the topic reading. Is it necessary to do this?
<? php
$ Queue = $ rk-> newQueue ();
$ Topic1 = $ rk-> newTopic ("topic1");
$ Topic1-> consumeQueueStart (0, RD_KAFKA_OFFSET_BEGINNING, $ queue);
$ Topic1-> consumeQueueStart (1, RD_KAFKA_OFFSET_BEGINNING, $ queue);
...........
...........
...........
$ Topic1-> consumeQueueStart (100, RD_KAFKA_OFFSET_BEGINNING, $ queue);
Probably, I missed something. Please tell me how to achieve the correct solution of the problem?