You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Now consumer can not subscribe to the topic. There is only a possibility to assign to a specific partition of topic. And if partition is not specified then the consumer assign to the zero partition.
public function receive($timeout = 0)
{
if (false == $this->subscribed) {
$this->consumer->assign([new TopicPartition(
$this->getQueue()->getQueueName(),
$this->getQueue()->getPartition(),
$this->offset
)]);
$this->subscribed = true;
}
$message = null;
if ($timeout > 0) {
$message = $this->doReceive($timeout);
} else {
while (true) {
if ($message = $this->doReceive(500)) {
break;
}
}
}
return $message;
}
Correct me if I am wrong
Now consumer can not subscribe to the topic. There is only a possibility to assign to a specific partition of topic. And if partition is not specified then the consumer assign to the zero partition.
Problems:
(this contradicts ideology of Kafka https://kafka.apache.org/intro#intro_consumers)
The text was updated successfully, but these errors were encountered: