KairosDB provides a useful API interface to develop plugins. To do this, we need to define the model, the service, and a parser for our data. The following is the proposed class diagram:
Class diagram of the Kafka KairosDB plugin
The Kafka module gets the properties from the file, starts the consumer, and instantiates the Kafka service:
@Provides private Consumer<byte[], byte[]> provideConsumerConnector( @Named("kairosdb.kafka.bootstrap.servers") String bootsrapserver, @Named("kairosdb.kafka.group.id") String groupid, TopicParserFactory factory) { Properties props = new Properties(); props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, ...
