1.1.0

[inaiat]

Automatically unsubscribe on shutdown_consumer to ensure cleanup

Description

This PR enhances the Kafka consumer cleanup process by automatically unsubscribing from topics when shutting down the consumer and changes the return type of recv() method in JavaScript.

Changes

• Added automatic unsubscribe call in shutdown_consumer method
• Updated logging messages to be more descriptive about the shutdown process
• Ensure shutdown signal is sent after unsubscribing
• Changed recv() method return type to be more TypeScript friendly

Testing

• Test consumer shutdown process
• Verify no hanging connections after shutdown
• Test resubscribing with a new consumer instance
• Test recv() method returns null on shutdown
• Test TypeScript type definitions

Breaking Changes

Yes. This includes a breaking change in the JavaScript/TypeScript API:

Before:

// Old return type
recv(): Promise<Message>

After:

// New return type
recv(): Promise<Message | null>

Consumers will need to update their null checks from:

const msg = await consumer.recv();
if (msg === null) {
  // handle no message (after call shutdownConsumer method)
}