kannar

When autocomplete is focused, the escape & tab shortcuts are not handled.

Create a component that portals a Calculator component on NumericInput (I didn't find a lovely library, but maybe you know one?) Then create its related Formiz field.

implement FieldDateSelector

3

Create the related form field for DateSelector component.

Akka Source add supervision configuration

3

The consumer used in the pulsar4s Akka Source is closed and stops the stream for every encountered error. I think we should use the supervision decider optionally passed to the...

Consumer creation exceptions are not handled

5

When creating to consume a non-exisiting namespace, the java pulsar client prints a lot of exceptions like: ``` org.apache.pulsar.client.api.PulsarClientException$LookupException: Policies not found for / namespace ``` This is normal, but...

Fix connection error handlers

4

Closes https://github.com/streamnative/pulsar-rs/issues/214. But based on https://github.com/streamnative/pulsar-rs/pull/216. Not fixed, but better information: Using a broker that never responds to `handleSend` messages in order to trigger timeout on the client's side. And...

Producer send incomplete batch after delay

2

A producer using batch is waiting for the batch to be full (batch_size reached) to send a message. Whenever the batch is created for a long time if the batch_size...

Closes https://github.com/streamnative/pulsar-rs/issues/212 I'm not a rust developer, let's consider this PR as try to fix. Feedbacks appreciated.

Producer send failure doesn't set connection as failing

1

During a producer's send call, if the connection fails to send the message, the error management doesn't set the connection as failing at this line: https://github.com/streamnative/pulsar-rs/blob/c31fc8335e4e321c85e0024aa4189c318a581082/src/producer.rs#L721 And the in the...

The client's sender seems to create a task for each received proto message and never checks if the future finishes. https://github.com/streamnative/pulsar-rs/blob/c31fc8335e4e321c85e0024aa4189c318a581082/src/client.rs#L560 If a reconnection loop is ongoing then all the...