1.2.1

[inaiat]

Title

feat: add example for consumer events and shutdown handling

Description

This PR adds an example demonstrating proper event handling and graceful shutdown for Kafka consumers.

Changes

• Add examples/events.mjs showing:
  • Event subscription (onEvents)
  • Message processing
  • Graceful shutdown handling
  • Error handling
• Update README.md with event handling example section

Example Added

const consumer = new KafkaConsumer({
  brokers: ['localhost:9092'],
  groupId: 'test-group', 
});

// Event handling
consumer.onEvents((err, event) => {
  console.log('Event:', event.name, event.payload);
});

// Graceful shutdown
process.on('SIGINT', async () => {
  await consumer.unsubscribe();
  await consumer.shutdownConsumer();
});

Testing Done
Verified event emission for:
Rebalancing
Commits
Consumer shutdown
Tested graceful shutdown behavior
Confirmed proper cleanup of resources