Add support for commitOffsets functions from kafkajs in class ClientKafka

[davidschuette]

Is there an existing issue that is already proposing this?

• I have searched the existing issues

Is your feature request related to a problem? Please describe it

There is no option to manually commit offsets when comsuming kafka events.

Describe the solution you'd like

Provide commitOffsets function from native kafkajs via ClientKafka implementation.

constructor(@Inject('KAFKA') private readonly client: ClientKafka) {}
...
@EventPattern('pattern')
consumeEvent(@Payload() data: any, @Ctx() context: KafkaContext) {
  this.client.commitOffsets(...)
}

If this idea gets approval I will start working on a PR and I am happy to update the docs as well.

Teachability, documentation, adoption, migration strategy

Developers will be able to manually commit offsets instead of auto commit. In production this is essential when using kafka.

What is the motivation / use case for changing the behavior?

Need to manually commit offsets when working with kafka in production.

[kamilmysliwiec]

Contributions are more than welcome!

[davidschuette]

These are all the changes I am planing to make to ClientKafka.

public commitOffsets(
  topicPartitions: TopicPartitionOffsetAndMetadata[],
): Promise<void> {
  return this.consumer.commitOffsets(topicPartitions);
}

Does such a simple function require a test?

[kamilmysliwiec]

I think no tests are needed in this case.

[kamilmysliwiec]

Let's track this here #9270