Hands-On Industrial Internet of Things

Installing the Kafka KairosDB plugin

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, ...