Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-3710

MemoryOffsetBackingStore creates a non-daemon thread that prevents clean shutdown

    Details

      Description

      MemoryOffsetBackingStore creates an ExecutorService but MemoryOffsetBackingStore.stop() fails to call executor.shutdown(). This creates a zombie non-daemon thread which prevents clean shutdown when running a StandaloneHerder embedded in another application.

      Note that FileOffsetBackingStore extends MemoryOffsetBackingStore so is also affected.

        Attachments

          Activity

            People

            • Assignee:
              ewencp Ewen Cheslack-Postava
              Reporter:
              davispw Peter Davis
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: