@Autowired
KafkaProducer<String, Bytes> kafkaProducer;
@Autowired
- org.apache.kafka.clients.consumer.Consumer<String, ClientMessage> kafkaConsumer;
- @Autowired
KafkaConsumer<Bytes, Bytes> offsetConsumer;
@Autowired
ApplicationProperties applicationProperties;