nicolaferraro opened a new issue #2901:
URL: https://github.com/apache/camel-quarkus/issues/2901


   I'm running a simple integration in Camel K:
   
   ```
   
from('kafka:bitcoin-kafka-topic?brokers=my-cluster-kafka-bootstrap.kafka-demo.svc.cluster.local:9092&groupId=myowngroupid&autoOffsetReset=earliest')
       .to('log:info')
   ```
   
   I'm using `myowngroupid` to reprocess old messages using a different 
consumer group. But when I run this integration, I notice that the Kafka group 
Id is always a fixed string `camel-k-integration`.
   
   The reason seems to be due to this part of the code: 
https://github.com/apache/camel-quarkus/blob/9344d527b2979a859e3678746bb55e54fa1abcc5/extensions/kafka/runtime/src/main/java/org/apache/camel/quarkus/component/kafka/QuarkusKafkaClientFactory.java#L63-L67
   
   Which seems correct at first glance, but unfortunately the Quarkus config 
unexpectedly contains wrong values at runtime:
   
   ![Screenshot from 2021-07-13 
16-09-11](https://user-images.githubusercontent.com/4151857/125469077-fa5bd046-46d2-4d63-a390-ac67afdcef39.png)
   
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to