Hi Daniel, Generally speaking, a solution that always works is to create your bundle with private packages/ship all kafka packages (general comment in OSGi/Karaf).
If you want to use the import package approach, the ServiceMix bundles should work (I didn't try recently, but I tried while ago). About your error, I checked and LogAndFailExceptionHandler class is present in the kafka-streams bundle. Do you have the import in your bundle (as I guess the kafka.common.Config is in your bundle classloader, so looking for LogAndFailExceptionHandler class in the same classloader) ? Regards JB On Sat, Mar 26, 2022 at 7:01 AM Daniel Las <[email protected]> wrote: > > Hi, > > Did anybody manage to start Kafka streams application in Karaf? I tried > different approaches: > > * use ServiceMix kafka-clients and kafka-streams bundles (2.8.1_1) > * repackage kafka-streams and make it a fragment for kafka-clients > * shade my bundle with kafka-clients and kafka-streams included > > and every time fail with a class loading issue related to default > configuration template built inside kafka-streams, specifically: > > Caused by: org.apache.kafka.common.config.ConfigException: Invalid value > org.apache.kafka.streams.errors.LogAndFailExceptionHandler for configuration > default.deserialization.exception.handler: Class > org.apache.kafka.streams.errors.LogAndFailExceptionHandler could not be found. > > Best regards > > -- > Daniel Łaś >
