Ask Your Question

Revision history [back]

click to hide/show revision 1
initial version

unexpected status when StageException occurred and can't stop the pipeline

error message: com.streamsets.pipeline.api.StageException: KAFKA_50 - Error writing data to the Kafka broker: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.

Sometimes, the pipepline turned into RUNNING_ERROR instead of RESTRY from RUNNING when above error occurred, i always can't stop or delete this pipeple except for restarting the service.