Rafał Solarski
Rafał Solarski
> Example of the workaround mentioned by @edenhill: > > ``` > kcat -C \ > -b $KAFKA_BROKER \ > -t $KAFKA_TOPIC \ > -o beginning \ > -J \...
I'm still thinking about enabling this mechanism to work in our tests, because unfortunately there is a slightly different classloader arrangement in them, so DefaultAsyncExecutionConfigPreparer is not loaded in FlinkUserCodeClassLoader...
fixed in https://github.com/TouK/nussknacker/pull/6055 and https://github.com/TouK/nussknacker/pull/6204