Is it possible to use checkpointstore-jedis in spring-cloud-azure-starter-integration-eventhubs

Feona Sun 0

I am learning about the Azure event hub service, and trying to integrate it with spring by using spring-cloud-azure-starter-integration-eventhubs.

I'd like to use azure-messaging-eventhubs-checkpointstore-jedis as checkpoint-store instead of Blob, I am not sure is this feasible. If not feasible, how to implement this?

Is there anyone could give some directions?

Thanks.

PRADEEPCHEEKATLA-MSFT 89,466 Reputation points Microsoft Employee

2023-05-16T09:33:14.3333333+00:00

@Feona Sun - We are reaching out to the internal team to get more information related to your query and will get back to you as soon as we have an update.
PRADEEPCHEEKATLA-MSFT 89,466 Reputation points Microsoft Employee

2023-05-19T07:08:01.3033333+00:00

@Feona Sun - Just checking in to see if the below answer provided by @Bruno Lucas helped.

If this answers your query, do click Accept Answer and Yes for was this answer helpful. And, if you have any further query do let us know.

1 answer

Bruno Lucas 4,431 Reputation points MVP

2023-05-16T10:25:54.1833333+00:00

Hi

The Consumer code could use an alternative storage and look like that's what that code is doing.

This code has the instructions: https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-jedis/src/samples/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisCheckpointStoreSample.java

how to create the redis:

https://video2.skills-academy.com/en-us/azure/azure-cache-for-redis/quickstart-create-redis

add the redis host name:

Then add the key:

This should do for the checkpoint storage. The rest is like any other event hub consumer:
Please sign in to rate this answer.
Feona Sun 0 Reputation points

2023-05-16T16:14:52.3433333+00:00

Hi Lucas，

Thanks for your reply.

I see the Jedis Sample and it seems that only works with pure Java API. But I am wondering how to integrate it with spring-cloud-azure-starter-integration-eventhubs?

For example, the eventhubs-integration code sample https://github.com/Azure-Samples/azure-spring-boot-samples/tree/spring-cloud-azure_v4.3.0/eventhubs/spring-cloud-azure-starter-integration-eventhubs/eventhubs-integration. I checked the configuration, azure blob checkpoint-store is configured :

https://github.com/Azure-Samples/azure-spring-boot-samples/blob/spring-cloud-azure_v4.3.0/eventhubs/spring-cloud-azure-starter-integration-eventhubs/eventhubs-integration/src/main/resources/application.yaml

Since the spring cloud event hub configuration properties have no jedis config https://video2.skills-academy.com/en-us/azure/developer/java/spring-framework/configuration-properties-azure-event-hubs

Does this means that if I use spring-cloud-azure-starter-integration-eventhubs, I can only use blob checkpoint-store?

Thanks.

Bruno Lucas 4,431 Reputation points MVP

2023-05-18T10:28:40.6533333+00:00

Hi @Feona Sun

I think that spring boot example uses this class that only supports azure blob storage. Sometimes those libraries have source code available on github and you can customize, but the regular version only runs with blob storage

Feona Sun 0 Reputation points

2023-05-18T13:06:13.98+00:00

Hi Lucas,

I will try to customize it, thanks very much.
Sign in to comment

Use comments to ask for clarification, additional information, or improvements to the question.

Share via

Is it possible to use checkpointstore-jedis in spring-cloud-azure-starter-integration-eventhubs

1 answer

Your answer