erializer". I get the
>>>> following Exception:
>>>>
>>>> org.apache.kafka.common.errors.SerializationException: Can't convert
>>>> value of class org.apache.storm.shade.org.json.simple.JSONObject to class
>>>> org.apache.kafka.common.serialization.StringSerializer specified in
>>>> value.serializer
>>>>
>>>>
>>>> I cannot find other serializers related to JSON, and I'm using storm
>>>> 1.0.2 and kafka 0.8.1.1.
>>>>
>>>> Could anyone help ?
>>>>
>>>> --
>>>> Thanks
>>>> Zhechao Ma
>>>
>>>
>>>
>>>
>>> --
>>> Thanks
>>> Zhechao Ma
>>
>>
>
>
>
> --
> Thanks
> Zhechao Ma
--
Regards,
Amber Kulkarni
files transmitted with it are confidential and intended
> solely for the use of the individual or entity to whom they have been
> addressed. If you are not the intended recipient, you are notified that
> disclosing, copying, distributing or taking any action in reliance on the
> contents of this information is strictly prohibited. Please notify the sender
> immediately by e-mail if you have received this e-mail by mistake and delete
> this e-mail from your system.
--
Regards,
Amber Kulkarni
thought you wanted to set clientId to be used. I missed other part of
>> the question to set consumer group to consume messages within that topology.
>>
>>
>>
>> On Wed, Jul 27, 2016 at 1:03 PM, Amber Kulkarni <
>> amber.kulkarn...@gmail.com> wrote:
>&g
nstructor and use respective clientId.
>
> TridentKafkaConfig(BrokerHosts hosts, String topic, String clientId)
>
> Can not you see that constructor in the version that you are using? I
> guess you should have that.
>
> Thanks,
> Satish.
>
>
> On Wed
stack overflow link here:
http://stackoverflow.com/questions/37967787/storm-trident-continuous-emits-from-aggregator-even-when-there-is-no-data-in-k
Regards,
Amber Kulkarni
up.
Please help, Thanks.
Regards,
Amber Kulkarni
