Debasish Ghosh

**Is your feature request related to a problem? Please describe.** Currently in `AkkaStreamlet` we have a way to indicate that the streamlet is ready for processing after it starts :...

This PR is a demonstration of using implicit serde from `kafka-streams-scala`. `example-dsl` now uses implicit serde.

https://forums.manning.com/posts/list/0/38628.page#p108028

https://forums.manning.com/posts/list/36686.page#p102437

> Starting with Redis 2.6.12 SET supports a set of options that modify its behavior: > EX seconds -- Set the specified expire time, in seconds. > PX milliseconds --...

Failing tests

1

Some tests are failing randomly. Not every time do they fail and also the failure set is different every time. Looks like some concurrency issues.

Defining the API

1

Is it a concern that the full contract of the API is not evident from the *Operations classes ? We need to get back to the commands to get an...

Introspection of beans often lead to processing same meta-data repeatedly .. e.g. List of Beans lead to processing of the bean meta-data many times (O(n)). Can this be improved with...