Hi, for a demostration, I need to replicate what showed in the makers blog https://www.plcnext-community.net/en/hn-makers-blog/591-connect-plcnext-control-via-mqtt-to-apache-kafka.html. I’m newbie with Java and when I have to edit the Java class DumbProcessor.java as indicated, I don’t know how modify the file with script as reported. In every attemp I have a compiling error. Only if I leave the file as downloaded in the repository I am able to compile without errors. I am not able to matching changes. What indicated in the blog --------------------------------------------- @Override public SourceRecord getRecords(String kafkaTopic) { return new SourceRecord{new SourceRecord(null, //sourcePartition null, //sourceOffset kafkaTopic, //topic null, //partition null, //keySchema mTopic, //key null, //valueSchema mMessage.toString(), //value new Long(123L))}; //long timestamp } ----------------------------------------------- What present in the script file -------------------------------------------- package com.evokly.kafka.connect.mqtt; import org.apache.kafka.connect.source.SourceRecord; import org.eclipse.paho.client.mqttv3.MqttMessage; /** * Copyright 2016 Evokly S.A. * * See LICENSE file for License **/ public interface MqttMessageProcessor { MqttMessageProcessor process(String topic, MqttMessage message); SourceRecord getRecords(String kafkaTopic); } -------------------------------------------- Could I have the exact entire script? Thanks in advance