Andrei Zhabinski

It's the intended behavior that comes from this test: ```julia @testset "Verify error callback is called" begin conf = Dict() conf["bootstrap.servers"] = "bad" ch = Channel(1) RDKafka.KafkaProducer(conf; err_cb=(err, reason) ->...

> If I want to test the local code from a Julia REPL, how can I do that? You need to _activate_ your environment. In the Julia REPL, type the...

You made it in a more creative way :) Yet, you don't have to remove all packages to work with a package locally.

No problem at all! There's no single "standard workflow", but it's easy to set up something that works for you. I forgot one detail. Let's say, you have just cloned...

As a general rule, you can follow the official documentation with a few context-specific modifications. I don't have a proper setup to test it myself, but I'd start with [this...

Can you post the full stacktrace? Edit: or even better the full log or its pieces related to JAR sending to workers.

For some reason, the added jar file is not propagated to your workers. Debugging this issue via Github issues isn't easy, but as a short in the night let's try...

What's your cluster config, e.g. cluster manager, remote or local workers, etc.? Usually, Spark creates project directories on workers dynamically, so putting jar files to some directory on workers beforehand...

It looks like Kafka jar is now being picked up, but versions of libraries still mismatch. Let's try to align them. In your local installation of Spark.jl, find a file...

> I added the Kafka clients package and it finally worked. Thanks for your assistance on that. Great! Could you please add a bit more details on what actions helped...