apache-kafka

4зной

1ответ

Тема не может быть найдена при создании сообщений: UNKNOWN_TOPIC_OR_PARTITION

У меня есть кластер kafka с двумя узлами (экземпляры EC2), где каждый узел используется как отдельный брокер. Когда я запускаю производителя на экземпляре лидера с помощью следующей команды: kafka-con

0зной

1ответ

Генератор потоков данных для Apache Kafka

Я ищу простой генератор событий/данных для Kafka-broker для выполнения некоторых тестов производительности для потоковых инструментов платформы Hadoop. Пока ничего не найдено. Он должен иметь возможно

1зной

1ответ

Apache Spark: функция reduceByKey останавливает Java-приложение

после долгого времени поиска его не могут помочь, и мне нужно спросить вас! Я хочу сделать простой Word Count из Hashtags из Tweets с Apache Spark. Приложение получает Hashtags от Kafka, и все работае

1зной

1ответ

Почему Kafka REST Proxy API не использует данные в формате JSON?

Я пытаюсь получить экземпляр узла сообщения с помощью API kafka rest. когда я буду посылать запрос пост через Клиента Почтальон и предоставление Content-Type в качестве приложения/vnd.kafka.json.v1 +

0зной

1ответ

Флинк: использование метки времени, которая включена в сообщение для оконного окна EventTime

Я принимаю сообщение от стримера Кафки во Флинк. В сообщении есть поле Record_time, и я хочу применить временное окно на основе Record_time. Могу ли я извлечь или использовать поле Record_time, чтобы

0зной

1ответ

Kafka Потребитель по разделам

Привет, группы потребителей, можно сказать потребителю только чтение определенного раздела? От того, что я читал и видел до сих пор, это не похоже на это или я что-то пропустил?

0зной

1ответ

Перенос журналов с помощью системного журнала-нг `, как is` без метки времени и имени хоста и т.д.

фон Сервер Apache работает на машине и производить бревна в /var/log/httpd/error_log Использование syslog-ng для отправки журнала в порт 5140 в конечном счете это будет потребляться kafka producer быт