projects / R / project-using-kafka-in-R.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 5b2ed10) | patch
Add ResetKafkaConsumerOffset function.
authorFrederik Vanrenterghem <frederik@vanrenterghem.io>
Fri, 14 Sep 2018 12:52:23 +0000 (20:52 +0800)
committerFrederik Vanrenterghem <frederik@vanrenterghem.io>
Fri, 14 Sep 2018 12:52:23 +0000 (20:52 +0800)
commit97a1f83851347df3f51eafd3d87476ff63682214
tree72f1b8cbdd35a19522cb5f2ef1cbcf0c4b3cc47atree | snapshot
parent5b2ed10b2cd8f0326a38e9658a3d5cecf2849c6ecommit | diff
Add ResetKafkaConsumerOffset function.

Add barebones R function to set a Kafka consumer's topic offset back to 0.
R/ResetKafkaConsumerOffset.R [new file with mode: 0644] blob
Exploring the use of Apache Kafka in R - with some website hits forecasting.