I'm having an issue running a Connect source worker running as a standalone herder embedded in a webapp. The webapp hangs on shutdown.
MemoryOffsetBackingStore creates an executor but doesn't call ExecutorService.shutdown() on stop(). I'd like to contribute a pull request. Question in the meantime: has anyone else encountered this or know of a workaround? My Source, incidentally, does not use offsets, but there doesn't appear to be a way to disable committing offsets. -Peter