У меня есть вариант использования, когда мне нужно опубликовать весь файл как одно сообщение с помощью Kafka Producer, чтобы, когда потребитель читает сообщение, потребитель мог получить весь файл. Я попытался реализовать это, преобразовав файл в массив байтов и опубликовав его в теме.
byte[] fileData = Files.readAllBytes(Paths.get(path));
producer.send(new ProducerRecord<String, byte[]>("test", fileData));
Когда то же самое потребляется, каждая строка приходит как отдельное сообщение
