Есть ли способ написать сообщение в кафке с некоторым таймаутом для каждого сообщения

Я новичок в кафке, и я знаю, что мы можем дать, например, delete.retention.ms при создании темы, и все сообщения, соответствующие этому критерию, будут удалены. Я хотел бы знать, есть ли способ указать этот критерий в каждом сообщении? А может есть какой-нибудь взлом для достижения цели?

ты смотрел этот Request.timeout.ms? в конфигурации производителя apache

Deadpool 10.08.2018 21:21

@Deadpool Они хотят, чтобы сообщения удалялись через определенное время. Вы упомянули, что клиент ожидает ответа сервера, а не то, что после OP.

Simon Clark 10.08.2018 23:53

я пытаюсь понять этот вопрос

Deadpool 10.08.2018 23:54
Построение конвейеров данных в реальном времени с Apache Kafka: Руководство по Python
Построение конвейеров данных в реальном времени с Apache Kafka: Руководство по Python
Apache Kafka - популярная платформа распределенной потоковой передачи данных, которую можно использовать для построения конвейеров данных в реальном...
1
3
134
1

Ответы 1

Учитывая, что сообщения Kafka представляют собой упорядоченный журнал, невозможно удалить сообщения из середина журнала. Поэтому я не верю, что то, о чем вы просите, возможно.

Другие вопросы по теме