SultanaJon opened a new issue, #230:
URL: https://github.com/apache/pulsar-dotpulsar/issues/230
So, I am new to pulsar and I am running into some issues that are causing
some confusion. I have setup a client, producer, consumer, and a reader. The
client, producer, consumer, and reader all build with no error and seem to
establish a connection when monitoring.
The first issue that I am having is that when I setup the reader, I request
`GetLastMessageIds`. This will return me two `MessageId`'s. The first with a
topic that has 'partition-0` concatenated to the end and the second with
'partition-1' concatenated to the end of the topic. Once I read these, I then
start to request the messages with the following code:
``` csharp
var messageIds = await reader.GetLastMessageIds();
await foreach(var message in reader.Messages(cts.Token))
{
Console.WriteLine($"Read message");
}
```
When reading the messages, I can read the first message but once it attempts
to read the second message, it hangs and the second message is never received.
This is strange to me because `GetLastMessageIds()` told me there were two
messages.
The second issue is with the consumer. Similar to the first issue, I can
request the `LastMessageIds` but with the consumer, I cannot read the earliest
messages. Attempting to get the messages from the consumer just hangs on the
foreach and neither the first or last message are received.
1. Why am I told there are two messages with `GetLastMessageIds` but I can
only read one with the reader?
2. Why can I not read any earliest messages with the consumer?
3. Why does [reader/consumer].GetMessages() hang at some point?
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
