Hello i'm working in a University project and i have really stack at this. I must create my own Kafka Serializer.I have do a lot of tries but i have this error... ![The Produxer Error](https://dev-to-uploads.s3.amazonaws.com/uploads/articles/59meqgpxc1sso7vyqs2p.png) this is my Producer ``` package org.example.kafkaApplication.Producer; import org.example.kafkaApplication.JsonSerializer; import org.apache.kafka.clients.producer.*; import java.util.Properties; public class ProducerMain { public static void main(String[] args) { Properties properties = new Properties(); properties.put("bootstrap.servers", "localhost:9092"); properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class.getName()); try (org.apache.kafka.clients.producer.Producer producer = new KafkaProducer<>(properties)) { for (int i = 0; i < 20; i++) { String taskId = "Task" + i; String studentId = "Student" + i; String subject = "Subject" + (i % 4); // 4 different work topics String dateOfSubmission = "2023-01-01"; Task task = new Task(taskId, studentId, subject, dateOfSubmission); ProducerRecord record = new ProducerRecord<>("task.events", task); producer.send(record); } } } } ``` this is my Object class ``` package org.example.kafkaApplication.Producer; import com.fasterxml.jackson.annotation.JsonInclude; import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonPropertyOrder; public class Task { @JsonInclude(JsonInclude.Include.NON_NULL) @JsonPropertyOrder({ "taskId", "studentId", "subject", "dateOfSubmission", }) @JsonProperty("taskId") private String taskId; @JsonProperty("studentId") private String studentId; @JsonProperty("subject") private String subject; @JsonProperty("dateOfSubmission") private String dateOfSubmission; public Task(String taskId, String studentId, String subject, String dateOfSubmission) { this.taskId = taskId; this.studentId = studentId; this.subject = subject; this.dateOfSubmission = dateOfSubmission; } @JsonProperty("taskId") public String getTaskId() { return taskId; } @JsonProperty("taskId") public void setTaskId(String taskId) { this.taskId = taskId; } @JsonProperty("studentId") public String getStudentId() { return studentId; } @JsonProperty("studentId") public void setStudentId(String studentId) { this.studentId = studentId; } @JsonProperty("subject") public String getSubject() { return subject; } @JsonProperty("subject") public void setSubject(String subject) { this.subject = subject; } @JsonProperty("dateOfSubmission") public String getDateOfSubmission() { return dateOfSubmission; } @JsonProperty("dateOfSubmission") public void setDateOfSubmission(String dateOfSubmission) { this.dateOfSubmission = dateOfSubmission; } } ``` this is my jshonScema ``` { "type": "object", "javaType" : "org.example.kafkaApplication.Producer.Task", "properties": { "taskId": { "type": "string" }, "studentId": { "type": "string" }, "subject": { "type": "string" }, "dateOfSubmission": { "type": "string" } }, "required": ["taskId", "studentId", "subject", "dateOfSubmission"], "additionalProperties": false } ``` and this is my pom.xml ``` 4.0.0 org.example KafkaApplication 1.0-SNAPSHOT 17 17 UTF-8 2.16.2 org.apache.maven.plugins maven-compiler-plugin 3.8.0 ${java.version} ${java.version} org.jsonschema2pojo jsonschema2pojo-maven-plugin 0.5.1 generate ${project.basedir}/src/main/resources/schema/ ${project.basedir}/src/main/java/ false false org.apache.kafka kafka-clients 3.6.1 org.slf4j slf4j-api 2.0.7 org.slf4j slf4j-simple 2.0.5 test ch.qos.logback logback-classic 1.4.14 test com.fasterxml.jackson.core jackson-core 2.16.1 com.fasterxml.jackson.core jackson-core 2.16.1 com.fasterxml.jackson.core jackson-databind 2.16.1 com.fasterxml.jackson.core jackson-annotations 2.16.1 commons-lang commons-lang 2.6 ``` Have you any idea?

koseran

<!Kafka Help Alert!>

Join Our Newsletter. No Spam, Only the good stuff.