Purge Kafka Topic

Is there a way to purge the topic in kafka?

I pushed a message that was too big into a kafka message topic on my local machine, now I’m getting an error:

kafka.common.InvalidMessageSizeException: invalid message size

Increasing the fetch.size is not ideal here, because I don’t actually want to accept messages that big.

24 Answers
24

Leave a Comment