问题描述
我正在通过JAVA使用事件中心触发器。
@FunctionName("XXXX")
public void myfunction(
@EventHubTrigger(name = "msg",eventHubName = "xxxxx",connection = "xxx",consumerGroup = "xxx") List<String> data,final ExecutionContext context) throws Exception {
}
我需要一种从上一个/旧的偏移量/序列号/日期时间开始的方法。在Azure函数中,我们应该在哪里指定要控制从哪个时间戳记/序列号开始从事件中心读取?
解决方法
EventPosition
类定义EventData
在事件中心分区中的位置。该位置可以是偏移量,序列号或排队时间。
参考:EventPosition Class - Azure SDK for Java
以下是Java中与EventPosition
相关的一些代码示例:EventPosition - Java Code Examples