Hi Michael, Can you open a JIRA and send a pull request on github.
Thanks, Harsha
On Fri, Nov 21, 2014, at 05:38 PM, Michael Schonfeld wrote:
> Hey guys,
>
> I'd like to add event listeners to KafkaSpout's .commit().
> Specifically, I'm looking to add the ability to listen when a commit
> happens, and get the last completed offset. It'll look somewhat like
> this: ``` new
> KafkaSpout(SpoutConfig).addCommitListener(KafkaCommitListener);
>
> public interface KafkaCommitListener { void onCommit(PartitionManager
> manager, Long lastCompletedOffset); } ```
>
> Should I simply submit a PR? Or, as per storm-contrib's instructions,
> may I get commit permissions to that repo?
>
> Thanks,
> - Michael S
