Kafka consumer problem

For clarity:

  • The KafkaAdapters.TimeSeriesProducer adapter is an OutputAdapter from the perspective of the openPDC, so here you would need to define input measurements for the adapter coming from the openPDC that would be published to Kafka.

  • The KafkaAdapters.TimeSeriesConsumer adapter is an InputAdapter from the perspective of the openPDC, so here you need define output measurements for the adapter coming from Kafka that would be published to openPDC - note that these measurements will need to be manually created in the openPDC in order to be available for processing by openPDC.