Azure-sdk-for-java: [QUERY] Spring - can we specify partition key when producing events to event hubs using azure-spring-cloud-stream-binder-eventhubs?

[saragluna]

Copied from https://github.com/microsoft/spring-cloud-azure/issues/764

Query/Question

I'd like to be able to specify a partition key when producing events to event hubs using azure-spring-cloud-stream-binder-eventhubs.
Is the property spring.cloud.stream.bindings.<channelName>.producer.partitionKeyExpression supported ?

[saragluna]

Hi @rodrigolopes,

According to this code segment, it's supported to specify a partition key when sending messages to the Event Hubs:

https://github.com/Azure/azure-sdk-for-java/blob/6bc09878bc7fd49ff76611ac604d30fae2defb50/sdk/spring/azure-spring-integration-core/src/main/java/com/azure/spring/integration/core/api/reactor/DefaultMessageHandler.java#L162-L177

However, the channel binder doesn't use the property as partitionKeyExpression:

https://github.com/Azure/azure-sdk-for-java/blob/4600d55e77a44e51cd458e9e6a94ebf5e1553774/sdk/spring/azure-spring-cloud-stream-binder-eventhubs/src/main/java/com/azure/spring/eventhub/stream/binder/EventHubMessageChannelBinder.java#L50-L66

[saragluna]

We'll check whether to use spring.cloud.stream.bindings.<channelName>.producer.partitionKeyExpression directly in our implementation.