Kafka to Kafka with Timestamp Router

• Use the quickstart for https://strimzi.io/quickstarts/ and follow the minikube guide.

• The Log Sink Kamelet is not available out of the box in 1.5.0 Camel-K release so you'll have to install it before installing the flow binding.

• If camel-k has been installed in a specific namespace different from the default one, you'll need to add a parameter to all the commands (-n <namespace_name>)

• Run the following commands

  • kubectl apply -f log-sink.kamelet.yaml -n kafka
  • kubectl apply -f flow-binding.yaml -n kafka

• Check logs

kamel logs kafka-to-kafka-with-timestamp-router

You should data ingesting from test-topic topic, into a $[topic]_$[timestamp] topic, based on the record timestamp.