Cheskel Twersky

### Related Template(s) pubsub_to_elasticsearch ### What happened? sometimes when using the temple and writing to es fails the temple will fail when trying to send the message back to pubusb...

calling setOptions on subscriber does not take effect

5

if changing flowControl settings after calling .on they dont not get into effect ``` const subscription = pubSubClient.subscription(subscriptionNameOrId); const messageHandler = message => { message.ack(); }; subscription.on('message', messageHandler); // does...

propagate set options to LeaseManager

3

Fixes #1879

fix: set MaxBytes for AckQueue

1

Fixes #1864

fixes: #90

This fixes #68 while also improving error logging

when trying to run i get `KeyError: 'nextResultUri'`. the response data is ``` {'resultType': 'EOS', 'isQueryResult': False, 'resultKind': 'SUCCESS', 'results': {'columns': [{'name': 'result', 'logicalType': {'type': 'VARCHAR', 'nullable': True, 'length': 2147483647},...

When a new pod gets added, it gets marked healthy right away instead of waiting for the lb to mark it so. anyone else seeing this? ``` Pod is in...

Errors are not sent back to the caller

12

im using the kafkaJs variant and `producer.send` and i was observing logs like this that were not send back to the caller. ``` timestamp: 1717074105728 fac: 'REQTMOUT', message: '[thrd:sonic-cluster-broker-1.kafka.internal.triplestack.io:9092/1]: sonic-cluster-broker-1.kafka.internal.triplestack.io:9092/1:...