我正在尝试使用pyspark从eventhub读取事件流。我无法将起始位置设置为流的开头。在scala中这一点很清楚,但对于python,我不断得到:
org.json4s.package$MappingException: No usable value for offset.
这是我的配置。
conf = {
"eventhubs.connectionString":
"Endpoint=sb://XXXX;SharedAccessKeyName=XXX;SharedAccessKey=XXXX;EntityPath=XXXX",
"eventhubs.consumerGroup": "$Default",
"eventhubs.startingPosition": "-1"
}
1条答案
按热度按时间fcipmucu1#
在斯卡拉
参考:scala中的事件中心配置
通过pyspark在python中
通过sdk在python中
异步使用事件中心中的事件
以异步方式批量使用事件中心中的事件
使用检查点存储使用事件和保存检查点。
参考:python中的事件中心配置