Não consegui entender por que eu não consigo acessar os detalhes de um record como o Guilherme faz (não conheço muito de Java além do básico), por exemplo, no LogService, no método parse ele consegue acessar o tópico e a partição do record recebido, mas no meu código eu não consigo.
No código do Guilherme tem
private void parse(ConsumerRecord<String, String> record) {
System.our.println("LOG: " + record.topic());
System.our.println(record.key());
System.our.println(record.value());
System.our.println(record.offset());
}Mas no meu código o máximo que eu consigo fazer é
private void parse(ConsumerRecord<String, String> record) {
System.our.println(record);
}
Com certeza deve ser algum diferença nas versões das bibliotecas, da linguagem, compilador, etc.
Uma outra dica que pode indicar o problema, creio eu, é que eu não consigo usar "var" no meu código, preciso declarar o tipo da variável quando vou criar uma, por exemplo, não consigo fazer
var kafkaService = new KafkaService();Só funciona se eu fizer
KafkaService kafkaService = new KafkaService();Eu coloquei os arquivos do projeto no github, o link tá logo abaixo, olhando o código e as configurações do projeto fica mais fácil achar o problema.