Andrii Tsarenko

Results 6 comments of Andrii Tsarenko

Hi, thanks for opening the interesting issue! > Kafka Listener never load the Kafka Consumer Config and never trigger the @kafkaListener because `@EnableKafka` and `@KafkaListener` are registered differently in `Spring`,...

`MyPayload ` is simple _POJO_, based on [PracticalAdvice](https://github.com/thepracticaldeveloper/kafka-spring-boot-example/blob/master/src/main/java/io/tpd/kafkaexample/PracticalAdvice.java), tested with [@Payload PracticalAdvice payload](https://github.com/thepracticaldeveloper/kafka-spring-boot-example/blob/master/src/main/java/io/tpd/kafkaexample/HelloKafkaController.java#L53) - I removed all listeners and generated the first one with the `MyBeanFactoryPostProcessor`. P.S. I've updated the...

`MyPayload` class: ```java import com.fasterxml.jackson.annotation.JsonProperty; public class MyPayload { private final String message; private final int identifier; public MyPayload(@JsonProperty("message") final String message, @JsonProperty("identifier") final int identifier) { this.message = message;...

I generated `@KafkaListener` method with the following parameter and annotation: ```java public void consume(@Payload MyPayload myPayload){ ... } ``` in your case you have to generate method with [Message](https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/messaging/Message.html) parameter...

if you are using `SQL` database then you can just use [JdbcTemplate](https://spring.io/guides/gs/relational-data-access/), and configure manually (`postgresql` example with `org.postgresql:postgresql:42.2.16` dependency): ```java DataSourceBuilder dataSourceBuilder = DataSourceBuilder.create(); dataSourceBuilder.driverClassName("org.postgresql.Driver"); dataSourceBuilder.url("jdbc:postgresql://127.0.0.1:5432/myDb"); dataSourceBuilder.username("myUser"); dataSourceBuilder.password("MyPassword"); DataSource...