I’m seeing a lot of failures from a Kafka spout, despite no failures from any 
of the processing bolts showing any failures.

I configure the spout like this:

    SpoutConfig spoutConfig
      = new SpoutConfig(new ZkHosts(zookeeper,"/brokers"),
                        TOPIC,
                        "/" + TOPIC,
                        kafkaClientName);
    spoutConfig.scheme = new SchemeAsMultiScheme(new StringScheme());
    spoutConfig.forceFromStart = false;

    KafkaSpout spout = new KafkaSpout(spoutConfig);
    . . .
    builder_.setSpout(“my-spout”,spout,2);

I’ve tried it with 16 to match the number of partitions, but get the same 
behavior.  There is nothing in the logs from the spout.

Has anyone else run into this?

Thanks,

Patrick

Reply via email to