我在本地计算机上将一条太大的消息推入了一个kafka消息主题,现在我收到一个错误:
kafka.common.InvalidMessageSizeException: invalid message size
增加fetch.size这里并不理想,因为我实际上并不想接受那么大的消息.有没有办法在卡夫卡中清除主题？
在kafka中，我将保留政策设置为3天 server.properties
############################# Log Retention Policy #############################
...
log.retention.hours=72
...
主题retention.ms设置为172800000（48h）。
但是，/ tmp / kafka-logs文件夹中仍然有旧数据，并且没有一个被删除。更改这些属性后，我等待了几个小时。
有什么需要设置的吗？当前正在产生和使用所有主题。