What is the default port that the KSQL server listens on?
I am producing Avro data on my Kafka cluster that is integrated with the Confluent Schema Registry. After a schema change that is incompatible, I know my data will be rejected. Which component will reject the data?
How does a consumer commit offsets in Kafka?