У меня возникли проблемы с усеченными сообщениями с использованием библиотеки cppKafka: я создаю с использованием BufferedProducer и этой конфигурации:
Configuration config = {{"metadata.broker.list", ip},
{"auto.offset.reset", "largest"},
{"queue.buffering.max.ms", 0},
{"api.version.request", true},
{"queue.buffering.max.ms", 50},
{"message.max.bytes", "16777216"},
{"compression.codec", "snappy"}};
И использует эту конфигурацию:
Configuration config = {{"metadata.broker.list", ip},
{"auto.offset.reset", "largest"},
{"group.id", group_id},
{"message.max.bytes", "16777216"},
{"compression.codec", "snappy"}};
Моя проблема заключается в следующем: некоторые массажи усечены. Либо конец отсутствует, либо первые символы заменяются специальными символами.
�h�� например.
Кто-нибудь имеет представление о том, что может вызвать эту ошибку?