3

我正在尝试在 JAVA 中查找自定义检查点管理器的示例，它可以将检查点数据存储在本地文件夹中。

基本上，我正在构建一个 java 应用程序，它从具有多个消费者组的 azure 事件中心读取数据。以前，我使用存储帐户连接字符串和位于 azure blobs 中的存储容器来实例化 EventProcessorHost - 这工作正常。

POM 条目：

        <dependency>
            <groupId>com.microsoft.azure</groupId>
            <artifactId>azure-eventhubs-eph</artifactId>
            <version>2.4.0</version>
        </dependency>

用于实例化主机的 Java 代码：

storageConnectionString="DefaultEndpointsProtocol=https;AccountName=MyAccountName;AccountKey=MyAccountKey;EndpointSuffix=core.windows.net";
storageContainerName="MyContainerName",

EventProcessorHost host = new EventProcessorHost(
                EventProcessorHost.createHostName(hostNamePrefix),
                eventHubName,
                consumerGroupName,
                eventHubConnectionString.toString(),
                storageConnectionString,
                storageContainerName);

现在，要求是使用 Azure Databricks 群集中的本地文件夹（DBFS:/ 路径）来存储检查点数据。

我想我必须编写一个自定义检查点管理器来实现 ICheckpointManager。我能够在 SQL 数据库中找到执行此操作的示例，但我无法找到 CheckpointManager 将检查点数据存储在本地文件夹中的示例。

谁能帮忙，给我一个例子的链接或代码片段？

4

0 回答 0