我在本地计算机上将一条太大的消息推入了一个kafka消息主题,现在我收到一个错误:
kafka.common.InvalidMessageSizeException: invalid message size
增加fetch.size这里并不理想,因为我实际上并不想接受那么大的消息.有没有办法在卡夫卡中清除主题?
fetch.size
purge apache-kafka
apache-kafka ×1
purge ×1