[BUG] CONFWARN on consumer with auto.offset.reset

[therealsqvad]

Describe the bug
CONFWARN occurs when starting $consumer->consume();

To Reproduce
Steps to reproduce the behavior:

1. Start consumer with option auto.offset.reset

 $consumer = Kafka::createConsumer(['topic', 'topic2'], 'group1', $broker_addr)
            ->withOptions([
                'auto.offset.reset'                     => 'earliest'
            ])
            ->withHandler(function (ConsumedMessage $message) { })
            ->build();
 $consumer->consume();

2. We get the warning "Configuration property auto.offset.reset is a consumer property and will be ignored by this producer instance". But we did not launch a producer, only a consumer
3. We get the warning "Configuration property compression.codec is a producer property and will be ignored by this consumer instance". But we did not specify the option compression.codec

Why is the option compression.codec passed to getConsumerOptions , which is relevant only for the producer

laravel-kafka/src/Config/Config.php

Line 70 in b11aa8f

'compression.codec' => config('kafka.compression', 'snappy'),

Why is a producer created when calling consume()?

laravel-kafka/src/Consumers/Consumer.php

Line 78 in b11aa8f

$this->producer = app(KafkaProducer::class, [

Expected behavior
The consumer will start without errors or warnings.

Additional context
Logs:

%4|1645017413.959|CONFWARN|rdkafka#consumer-1| [thrd:app]: Configuration property compression.codec is a producer property and will be ignored by this consumer instance
%4|1645017413.963|CONFWARN|rdkafka#producer-2| [thrd:app]: Configuration property auto.offset.reset is a consumer property and will be ignored by this producer instance

[mateusjunges]

Hey @therealsqvad, i've created a pr to fix some issues i found while reading this.

Why is the option compression.codec passed to getConsumerOptions , which is relevant only for the producer

Since you passed the compression.codec via withOptions method, it is intended as a custom option, and it is passed to the consumer builder. The problem is that the consumer creates a new producer to send messages to the dead letter queue, and the producer was being created with the same config options. I added a filter to reject consumer options while creating a producer, and also to reject producer options while creating consumers.

Thanks for reporting.

[therealsqvad]

@mateusjunges Thank you