.
Regards,
-Anandh Kumar
.
Regards,
-Anandh Kumar
On Thu, Sep 16, 2021 at 12:50 PM Jonas Krauss wrote:
> Hi Anandh,
>
> according to the error message, your class lacks a simple no arguments
> constructor like this:
>
> public LocalDate() {}
>
> Kryo needs this for working properly when doing deseriali
:?]
at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:793)
~[kryo-3.0.3.jar:?]
Regards,
-Anandh Kumar
Hi Nikos,
My topic have 6 partition so my kafka-spouts parallelism hint also 6.
My worker is 10
KafkaSpout executor is 6
Only with Kafka-spout without bolt I got 1,00,000/s but excepted 10,00,000/s
Regards,
-Anandh Kumar
On Mon, Apr 18, 2016 at 8:53 PM, Nikos R. Katsipoulakis <
nick.
test in my environment.
Regards,
-Anandh Kumar
On Sat, Apr 16, 2016 at 8:44 PM, Nikos R. Katsipoulakis <
nick.kat...@gmail.com> wrote:
> Hello Anandh,
>
> Why do you keep the max.spout.pending this low? I suggest increasing it to
> a higher value, because this might be the
parameters( send,receive buffer) not use.
Please help me.
Regards,
-Anandh Kumar
Hi,
In storm 1.0.0. version new KafkaSpout API released.
Need simple examples how we can use new KafkaSpout API?
Please help me .
Regards,
-Anandh Kumar