I'm having some trouble with a couple of items in consuming and production of messages with kafka using camel. Any help is appreciated.
Is there a way that I can set the kafka config item group.initial.rebalance.delay.ms for the camel kafka consumer? The default of 3000 msecs isn’t long enough as I launch on multiple machines and want them to have more time to sync and prevent re-sync. Also I'm can't seem to get compression working on the topic I'm forwarding to. I'm setting "compressionCodec=snappy" which the program accepts, but no compression is done. I'm consuming from a topic that is not compressed and sending to a topic where I want it compressed. I see the snappy jar is part of the classpath and don't get any errors in startup or execution.
