SelfDescribingStateKeyClient
@Singleton
@Requires(property = "airbyte.destination.core.data-channel.medium", value = "SOCKET")
Calculates state / partition keys based off the incoming State message. States and Partitions may be either 1 to 1 or 1 to many.
Only for use for multithreaded "speed-mode" input streams. Source must specify partition / id on the State message.