source kafka sink console error

config

env {
parallelism = 1
job.mode = "BATCH"
}

source {
Kafka {
schema = {
fields {
id = "int"
name = "string"
price = "double"
category = "string"
}
}
format = json
topic = "yyyyy"
bootstrap.servers = "43.139.107.144:9092"
kafka.config = {
client.id = client_1
auto.offset.reset = "latest"
}
}
}

sink {
Console {}
}

Start by reproducing the supplied Kafka-to-Console BATCH configuration and inspect the attached screenshot for the exact error. Compare the Kafka source and Console sink behavior to identify the failing component; done means the configuration runs without the reported console error and a regression test covers it.

Written by the indexing model from the issue text.