Package org.eso.ias.command.kafka

package org.eso.ias.command.kafka
  • Classes
    Class
    Description
    CommandManagerKafkaImpl
    The CommandManagerKafkaImpl is the command executor that subscribes as a consumer of the kafka command topic to get commands and as producer of the kafka reply topic to publish replies Its task is to receive the commands on behalf of the process where it runs, discarding the commands targeted to other processes.
    ReplyKafkaConsumer
    An helper class to easily consume replies from the kafka reply topic.