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
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.