Kafka producer hangs if topic doesn’t exist
I’m new to Kafka and trying to implement a simple producer, sending data to a topic. If the topic doesn’t exist, I want to handle the sutiation as an exception. private Producer
Tag: kafka-producer-api
What is reason for getting ProducerFencedException during producer.send?
Trying to load around 50K messages into KAFKA topic. In the beginning of few runs getting below exception but not all the time. org.apache.kafka.common.KafkaException: Cannot execute transactional …