Hi @rhauch, @ewencp et al., here's a proposal for 
[KAFKA-3821](https://issues.apache.org/jira/browse/KAFKA-3821) based on my 
latest comment on the JIRA issue. It'd need more polishing and testing, but I 
wanted to demonstrate the idea and see whether you agree with it before 
spending more time on it.

I think it's the simplest way to let source connectors produce offsets without 
emitting messages and without creating an awkward inheritance relationship of 
`SourceRecord` and a sub-class just carrying offset information. Please see 
[this 
comment](https://issues.apache.org/jira/browse/KAFKA-3821?focusedCommentId=16564900&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-16564900)
 on the JIRA issue for the two use cases of this new functionality.

Looking forward to learn about your toughts. Thanks!

### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation 
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)


[ Full content available at: https://github.com/apache/kafka/pull/5553 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to