satishviswanathan opened a new issue, #277:
URL: https://github.com/apache/pulsar-dotpulsar/issues/277
### Description
I have a pulsar client created with a one producer created for a topic and
ran a load tests and I could see that few of the messages are lost. In the
current implementation is message delivery guaranteed with a publisher
confirmation ?
**Client and Producer code**
builder = PulsarClient.Builder()
.Authentication(AuthenticationFactory.Token(TOKEN))
.CheckCertificateRevocation(true)
.ExceptionHandler(new CustomExceptionHandler())
.KeepAliveInterval(new TimeSpan(0, 0, 30))
.RetryInterval(new TimeSpan(0, 0, 2))
.CloseInactiveConnectionsInterval(new TimeSpan(0, 0,
30));
builder.ConnectionSecurity(EncryptionPolicy.EnforceEncrypted)
.ServiceUrl(new
Uri($"pulsar+ssl://{pulsarHostName}:6651"))
.TrustedCertificateAuthority(Certificate.GenerateCertificate(certificateOption.Value.Pulsar.Ca))
.VerifyCertificateAuthority(true)
.VerifyCertificateName(false);
_client = builder.Build();
_producer = _client.NewProducer(Schema.ByteArray)
.ProducerName($"{@event}-{Environment.MachineName}")
.StateChangedHandler(producerStateChanged =>
{
var topicName = producerStateChanged.Producer.Topic;
var state = producerStateChanged.ProducerState;
_logger.LogDebug(new ApplicationLogMessage
{
Message = $"The producer for topic '{topicName}' changed state
to '{state}'"
});
})
.Topic($"persistent://viteglobal/seed/Test)
.Create();
**Publisher code**
var messageId = await producer.Send(new MessageMetadata(), byteArray,
CancellationToken.None).ConfigureAwait(false);
### Reproduction Steps
The publisher code is exposed via an http end point.
Run a load test
Number of users : 10
Number of iterations : 20
### Expected behavior
Expected: 200 Messages to be published.
### Actual behavior
There are few messages loss with EntryId and LedgerId returned as negative
values
### Regression?
_No response_
### Known Workarounds
_No response_
### Configuration
_No response_
### Other information
_No response_
--
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]
