oven-baked opened a new issue #68:
URL: https://github.com/apache/pulsar-dotpulsar/issues/68
I've been generating messages in a Python Pulsar function and spitting them
out a receiving topic.
When I consume from that topic using the client app bundled with Pulsar,
everything works okay and I can pull down and see my resulting messages.
If the DotPulsar consumer tries to pick up any of those messages from the
function, it immediately enters a faulted state.
The exception message is "{"Specified argument was out of the range of valid
values. (Parameter 'length')"}"
I've been able to pull the following stack trace from the library:
`System.ThrowHelper.ThrowStartOrEndArgumentValidationException(Int64 start)
at System.Buffers.ReadOnlySequence`1.Slice(Int64 start, Int64 length)
at DotPulsar.Internal.BatchHandler.Add(MessageIdData messageId, UInt32
redeliveryCount, MessageMetadata metadata, ReadOnlySequence`1 data) in
C:\Users\X2012039\source\repos\pulsar-dotpulsar\src\DotPulsar\Internal\BatchHandler.cs:line
51
at DotPulsar.Internal.ConsumerChannel.<Receive>d__9.MoveNext() in
C:\Users\X2012039\source\repos\pulsar-dotpulsar\src\DotPulsar\Internal\ConsumerChannel.cs:line
89
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task
task)
at
System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task
task)
at System.Threading.Tasks.ValueTask`1.get_Result()
at
System.Runtime.CompilerServices.ConfiguredValueTaskAwaitable`1.ConfiguredValueTaskAwaiter.GetResult()
at DotPulsar.Internal.Consumer.<Receive>d__17.MoveNext() in
C:\Users\X2012039\source\repos\pulsar-dotpulsar\src\DotPulsar\Internal\Consumer.cs:line
99
at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task
task)
at
System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task
task)
at System.Threading.Tasks.ValueTask`1.get_Result()
at
System.Runtime.CompilerServices.ConfiguredValueTaskAwaitable`1.ConfiguredValueTaskAwaiter.GetResult()
at DotPulsar.Internal.Executor.<Execute>d__9`1.MoveNext() in
C:\Users\X2012039\source\repos\pulsar-dotpulsar\src\DotPulsar\Internal\Executor.cs:line
136`
----------------------------------------------------------------
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:
[email protected]
