Kafka Pack should provide a default way of handling instance changes

Description

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.

Release Notes

None

Activity

Show:

Terence YimApril 25, 2019 at 9:11 PM

This is related to Flow pack and Flow is removed as of 6.0

Won't Fix
Pinned fields
Click on the next to a field label to start pinning.

Details

Assignee

Reporter

Affects 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