Я новичок в кафке, и я знаю, что мы можем дать, например, delete.retention.ms при создании темы, и все сообщения, соответствующие этому критерию, будут удалены. Я хотел бы знать, есть ли способ указать этот критерий в каждом сообщении? А может есть какой-нибудь взлом для достижения цели?
@Deadpool Они хотят, чтобы сообщения удалялись через определенное время. Вы упомянули, что клиент ожидает ответа сервера, а не то, что после OP.
я пытаюсь понять этот вопрос
Учитывая, что сообщения Kafka представляют собой упорядоченный журнал, невозможно удалить сообщения из середина журнала. Поэтому я не верю, что то, о чем вы просите, возможно.
ты смотрел этот
Request.timeout.ms
? в конфигурации производителя apache