@KafkaHandler
private void createTicket(CreateTicketCommand command) {

@KafkaHandler
private void createTicket(String test) {

@Bean
public ProducerFactory<String, String> producerFactory() {
 Map<String, Object> configProps = new HashMap<>();
 configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
 configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
 configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
 return new DefaultKafkaProducerFactory<>(configProps);
}

@Bean
public <T> ProducerFactory<String, T> genericProducerFactory() {
 Map<String, Object> configProps = new HashMap<>();
 configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
 configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
 configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
 return new DefaultKafkaProducerFactory<>(configProps);
}

his.template.send(
  new GenericMessage<>(
    new CreateTicketCommand(
      accountId,
      ticketDto.getAmount()
    ),
    Collections.singletonMap(KafkaHeaders.TOPIC, createTicket)
  )
);