I believe you are overriding the value here:
spoutConfig.zkRoot = "/brokers”;
On Sep 17, 2016 9:29 AM, "Dominik Safaric" wrote:
> Already configured with an empty string, but unfortunately I keep getting
> the same message claiming no partitions can be found.
>
> Dominik Šafarić
>
> On 17 Sep 2
Already configured with an empty string, but unfortunately I keep getting the
same message claiming no partitions can be found.
Dominik Šafarić
> On 17 Sep 2016, at 18:11, Ambud Sharma wrote:
>
> The Zkroot should be empty string.
>
>
>> On Sep 17, 2016 9:09 AM, "Dominik Safaric" wrote:
>>
The Zkroot should be empty string.
On Sep 17, 2016 9:09 AM, "Dominik Safaric" wrote:
> Hi,
>
> I’ve deployed a topology consisting of a KafkaSpout using Kafka 0.10.0.1
> and Zookeeper 3.4.6. All of the services, including the Nimbus and
> Supervisor, run on the same instance.
>
> However, by exa
Hi,
I’ve deployed a topology consisting of a KafkaSpout using Kafka 0.10.0.1 and
Zookeeper 3.4.6. All of the services, including the Nimbus and Supervisor, run
on the same instance.
However, by examining the worker.log file, I’ve found that the KafkaSpout is
unable to find partitions informat
