У меня 20 или около того процессов, которые генерируют журналы (~ 500 МБ каждый) на своих...
Если потоковое приложение с состоянием запускается с 6 потоками на одном узле, произойдет ли...
Я работаю над переносом моего старого инструмента индексирования в solr (версия 7).Но я не совсем...
Я пытаюсь интегрировать Avro и Schema Registry в наши конвейеры данных Kafka.Теперь он выглядит...
У меня есть сценарий, в котором я должен отправить данные через Kafka во Flink.Сейчас я использую...
У нас есть клиент Kafka 1.0 с spring-kafka (версия 1.1.1.RELEASE), потому что наша среда Spring -...
Я прочитал документы Кафки Но я не понял.Могу ли я использовать имя пользователя и пароль для...
Я пытаюсь выполнить тест производительности в нашей среде kafka.Я играл с несколькими...
Когда производитель Kafka вызывает метод send (), он возвращает будущее RecordMetadata, которое...
Я не понимаю, как работает logcompaction. Я создал тему для настройки и использую эту тему...
Я знаю, что каждый раздел выделен одному потребителю Kafka (внутри группы потребителей), но один...
Я использую Кафку 0.11.Я пытаюсь сбросить смещение темы в группе потребителей, но не вижу...
Я получаю эту ошибку в журналах заказов: 2018-05-31 19:22:31.010 IST [orderer/consensus/kafka] try...
Наша топология использует KafkaSpout для извлечения сообщений из тем Кафки.У нас есть ~ 150 тем с ~...
Я пытаюсь запустить kafka на 3 компьютерах как кластер, я настроил Zookeeper на всех машинах.Сейчас...
Кафка коннект запускает новый коннектор и его задачи в процессе кафка коннект?или новый процесс JVM...
У меня должно быть приложение микросервиса отдыха производителя-потребителя Apache kafka, в котором...
Для передачи заказа мы создаем сообщение Кафки А, которое включает в себя все 30 полей для заказа....
Возможно ли связать клиента cometD с производителем Kafka?Любые предложения? В настоящее время у...
Я пытаюсь запустить приемник подключения Kafka для базы данных Oracle.Авро сообщение в кафке...
Я создал потребителя, используя следующую зависимость <dependency> <groupId>org.apache
на самом деле у меня есть приложение Spring Boot, и я использую встроенную kafka без использования...
В новом выпуске разъема HDFS Sink смещение хранилища было изменено.В старых выпусках мне удавалось...
Я занимаюсь разработкой простого приложения Kafka Stream, которое извлекает сообщения из темы и...
Каков наилучший способ проверить, сколько событий потребляется приложением из темы Kafka за...