sparkstreaming怎么手动提交偏移量

使用pyspark操作sparkstreaming读取kafka数据后，手动管理偏移量，应该如何提交？

kafka低级API可以手动提交偏移量