Basic ConnectionFactory
Refactoring
Reorganize DispatchingMessageListener
Separate offset management for fetching and consuming
Cleanup
Removed offset
Make KafkaResultBuilder package private
Cleanup