Hello Emanuele,
>From logs it seems that auto.create.topics.enable is not overriden for the
embedded broker.
It also seems that test is explicitly creating topic before publishing
message to it.
Consider commenting out explicit topic creation and rely on implicit topic
creation.
Kind regards,
Ste
Hi,
When trying to send a message to a local Kafka (created via
KafkaServerStartable), I'm getting loads of
(Logging.scala:83) - Error while fetching metadata [{TopicMetadata for
topic test_topic ->
No partition metadata for topic test_topic due to
kafka.common.LeaderNotAvailableException}] for
