Numaflow Kafka Sourcer/Sinker is a Numaflow user-defined source/sink connector for Apache Kafka. It allows you to read/write data from/to a Kafka topic using Numaflow. Integration with Confluent Schema Registry is also supported.
Use Case 1: Read data from Kafka with an Avro schema registered in the Confluent Schema Registry. See an example here.
Use Case 2: Read data from Kafka with no schema or JSON schema registered in the Confluent Schema Registry. See an example here.
Use Case 3: Write data to Kafka with an Avro schema registered in the Confluent Schema Registry. See an example here.
Use Case 4: Write data to Kafka with a JSON schema registered in the Confluent Schema Registry. See an example here.
Use Case 5: Write data to Kafka with no schema. See an example here.