[KAFKA-3710] MemoryOffsetBackingStore creates a non-daemon thread that prevents clean shutdown

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.0.1
• Fix Version/s: 0.10.1.0
• Component/s: KafkaConnect
• Labels: easyfix newbie patch
• Assignee: Ewen Cheslack-Postava
• Reporter: Peter Davis
• Created: 13/May/16 19:46
• Updated: 27/May/16 04:04
• Resolved: 27/May/16 04:04

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.

Issue Links

• links to: GitHub Pull Request #1383
• links to: GitHub Pull Request #1383