Terence Marks

Demeter chained mockery instances leaking memory

4

After calling `Mockery::close()` when creating mocks using the demeter chains, the created mock instances from the demeters seem to stay around in memory. Following is an example unit test demonstrating...

### Versions used ```"com.lightbend.akka" %% "akka-stream-alpakka-amqp" % "3.0.1"``` ```"com.typesafe.akka" %% "akka-stream" % "2.6.14"``` ### Expected Behavior When sending multiple messages via new instances of `AmqpFlow`, expecting connection to either recover...

`Kafka\ConsumerConfig` and `Kafka\ProducerConfig` access same static variable:    This causes issues for common options such as `'clientId'`, `'brokerVersion'`, etc. Ideally, the configs should have no shared properties.

Is there a way to share the same MQTT connection across multiple consumers via streaming API?

1

Hey, I was wondering if there was an easy way to share an MQTT connection across multiple MqttSources or update the topics which a source is currently subscribed to. I...