Kafka - simple way to copy data from one topic to another

Hi, looking for a simple way to copy data from one topic to another in the same cluster. can I use Replicator to do this … I see it is backed by a Kafka connect

> same cluster
Don’t use replicator. Use Kafka Streams

Or a ksqlDB INSERT … SELECT … statement.

Yeah … ksql seems to be the no code option … thnq

You’re welcome.

Oh, you’re probably going to want SET 'auto.offset.reset' = 'earliest'; if you want to start copying from the first event in the topic. Otherwise it’ll only copy new events.

Hi … it looks like ksql is trying to force avro field names to be upper when writing … is there a workaround without being explicitly defining schema in my persistent query…

appreciate your help

Ah yes , backprimes will force ksqlDB to preserve the case you specify. For example:

  `username` STRING
) ...```

I think schema inference solved my issue … Thnx … didnt want to explicitly define schema in ksql

Fair enough. Glad you got it solved. :slightly_smiling_face: