Won't Fix
Pinned fields
Click on the next to a field label to start pinning.
Details
Details
Assignee
NitinM
NitinMReporter
Gokul Gunasekaran
Gokul GunasekaranAffects versions
Components
Priority
Created January 26, 2016 at 2:30 AM
Updated April 25, 2019 at 9:11 PM
Resolved April 25, 2019 at 9:11 PM
i) The code to handle changes of Flowlet instances have to be implemented by the class extending KafkaConsumerFlowlet but a default way of handling it (sample logic is part of Kafka08ConsumingApp.KafkaSource).
Minor: If KafkaConsumerFlowet by default takes expects properties such as kafka.zookeeeper, kafka.brokers, kafka.topic, kafka.partitions with these keys, then I think it might reduce some code for the classes extending KafkaConsumerFlowlet.