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

Reply via email to