You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2020/06/23 09:48:57 UTC
[GitHub] [pulsar-client-go] JoseFMP opened a new issue #297: Messages not appearing in the output channel
JoseFMP opened a new issue #297:
URL: https://github.com/apache/pulsar-client-go/issues/297
#### Expected behavior
```
reader, errorCreatingReader := client.CreateReader(pulsar.ReaderOptions{
Topic: createTopicString(namespace, topic),
StartMessageID: pulsar.LatestMessageID(),
MessageChannel: messageChannel,
ReceiverQueueSize: 10,
})
```
In this scenario, `messageChannel` gets messages in the channel whenever they arrive from the broker.
#### Actual behavior
Messages do not appear in the channel.
Note that, if I issue reader.Next(), instead of setting MessageChannel, messages do appear in the channel.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] JoseFMP commented on issue #297: Messages not appearing in the output channel
Posted by GitBox <gi...@apache.org>.
JoseFMP commented on issue #297:
URL: https://github.com/apache/pulsar-client-go/issues/297#issuecomment-649183512
As said in my previous comments and I want to remark this with capital letters: YES.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] JoseFMP commented on issue #297: Messages not appearing in the output channel
Posted by GitBox <gi...@apache.org>.
JoseFMP commented on issue #297:
URL: https://github.com/apache/pulsar-client-go/issues/297#issuecomment-648056199
So, seems both things are broken. `MessageChanne` and `ReceiverQueueSize` are categorically ignored.
In addition, if you happen to use `StartMessageID: pulsar.LatestMessageID()` goold luck because you won't ever see a message coming to your reader.
Good luck.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] JoseFMP commented on issue #297: Messages not appearing in the output channel
Posted by GitBox <gi...@apache.org>.
JoseFMP commented on issue #297:
URL: https://github.com/apache/pulsar-client-go/issues/297#issuecomment-648041257
Note: Seems that the problem is `LatestMessageID()` if I use `EarliestMessageID()` it seems to work. Not also that in any case I ALWAYS make sure there are messages sent after the receiver is created.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] sijie commented on issue #297: Messages not appearing in the output channel
Posted by GitBox <gi...@apache.org>.
sijie commented on issue #297:
URL: https://github.com/apache/pulsar-client-go/issues/297#issuecomment-648531387
@JoseFMP If you use `pulsar.LatestMessageID()`, did you produce any messages after creating a reader?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] JoseFMP commented on issue #297: Messages not appearing in the output channel
Posted by GitBox <gi...@apache.org>.
JoseFMP commented on issue #297:
URL: https://github.com/apache/pulsar-client-go/issues/297#issuecomment-649906605
@sijie could this be related to time zones? i.e. is `pulsar.LatestMessageID()` working if the broker is in a different time zone than the pulsar client? Otherwise I really do not get any message if using `LatestMessageID()` I hope this gets fixed since the only work around I found is to `EarliestMessageID()` and discard all the queue. But obviously this won't work if the queue is too long.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org