Сначала я загружаю CSV-файл в тему Kafka и могу распечатать тему через программу Flink. Код выглядит следующим образом: final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); Properties prop = new...

Мы можем указать собственный разделитель для тем kafka. Таким образом, производитель kafka может детерминированно отправить сообщение в конкретный раздел на основе определенного настраиваемого алгоритма. Теперь вопрос в том, когда я увеличиваю...

Использую автосоздание тем в Кафке. Некоторые темы требуют уплотнения, некоторые нет. Можно ли указать собственные параметры при автоматическом создании темы; или мне нужно проверить наличие и создать его «вручную» с желаемыми параметрами, прежде...

В настоящее время работает с Kafka Streams для агрегирования событий в клиентской системе. При запуске нашего прототипа с фейковыми событиями все работает отлично. Однако при использовании реальных данных мы заметили, что в процессе агрегирования...

Я новичок в Kafka и пытаюсь создать новую тему на своем локальном компьютере. Я перехожу по этой ссылке . Вот шаги, которые я выполнил: Запустить zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties Запустить...

Я новичок в Кафке. Я пытаюсь отправить сообщение в тему Kafka, содержащую заголовок и полезную нагрузку. Ниже приведена ошибка: "org.apache.kafka.common.errors.SerializationException: Can't convert value of class...

Я новичок в Кафке. Я провожу эксперимент, как удалить сообщения в теме кафки. Я обнаружил, что если мы установим для свойства «retention.ms» для темы меньшее значение времени, скажем, 1 секунду, то через 1 секунду сообщения в теме будут удалены, как...

Мне нужно программно очистить или удалить темы Kafka с помощью языка С#. В настоящее время я использую библиотеку Confluent.Kafka для публикации и использования тем Kafka. Я могу удалить темы Kafka, используя командную строку, как это...

У меня есть тема, в которой все журналы помещаются в централизованную тему, но я хотел бы отфильтровать некоторые из этих записей в отдельную тему и сгруппировать, если это возможно. Спасибо

я хочу просмотреть свойства уровня темы что-то вроде "message.timestamp.type": "LogAppendTime", "cleanup.policy":"compact" можно ли просмотреть все свойства, установленные на уровне темы? есть ли какая-нибудь команда, где я могу просмотреть...

У меня есть приложение весенней загрузки, которое продолжает читать все сообщения из определенной темы. Моя проблема в том, что у меня проблема в том, что при перезапуске приложения ему нужно заново прочитать все сообщения из темы. Я думал, что эти...

В Kafka я знаю, что есть тема с именем __consumer_offsets , которая используется для хранения смещений потребителей. Насколько я понимаю, потребитель будет делать два типа вещей: получить данные из раздела. пишите офсеты в тему...

Я следил за книгой Kafka: The Definitive Guide First Edition, чтобы понять, когда сегменты журнала удаляются брокером. Согласно тексту, который я понял, сегмент не подлежит удалению, пока он не будет закрыт. Сегмент может быть закрыт только тогда,...