var msgs = new List<string> {“msg1”, “msg2”, “msg3”}; var tasks = new List<Task>();...
У нас есть тема с сообщениями со скоростью 1msg в секунду с 3 разделами, и я использую разъем HDFS...
Я пробую потоковые журналы из log4j2 в топик Кафки. Мой сервер zookeeper & kafka работает. Я уже...
KafkaProducer javadoc говорит, что использование одного экземпляра даст более высокую...
Я тестирую async send () в моем производителе кафки. Кластер, к которому я хочу подключиться,...
когда я записываю данные в тему kafka с использованием потоковой передачи Spark Direct 2.1, через...
Я использую производителя kafka и потребителя Spring kafka. Я использую сериализатор и...
Я сталкиваюсь с ошибкой ниже, когда пытаюсь вставить сообщение в Kafka через API производителя org
Привет, есть ли у кого-нибудь пример вызова в Kafka REST Proxy для отправки сообщения в тему, а...
Я установил Kafka " kafka_2.12-0.11.0.0 ". Запущены службы как zookeper , так и Кафка-сервер ....
Я хотел бы создать одно из значений атрибута в качестве partitionID для темы kafka.Например, мой...
Как это просто, возможно ли Stream Dtream в тему Kafka? У меня есть потоковое задание Spark,...
Я пытаюсь написать наивного продюсера Кафки, используя Java.Приложение принимает два ввода: Имя...
Можно ли использовать avro DataFileWriter с реестром схемы?
Я хотел бы иметь семантику "Точно один раз", но я не хочу читать сообщения с помощью Consumer.Я бы...
Как настроить log.cleanup.policy: сжатие с использованием конфигурации пружины
У меня должно быть приложение микросервиса отдыха производителя-потребителя Apache kafka, в котором...
Возможно ли связать клиента cometD с производителем Kafka?Любые предложения? В настоящее время у...
Я пытаюсь создать элементы, используя FlinkKafkaProducer010, однако, когда я открываю окно консоли...
Я работаю в Docker для Windows, и вот мои настройки NiFi: Подробная информация о процессоре...
У меня есть огромная масса записей данных для Kafka, использующих пакетную обработку и сжатие. Я...
Мы читаем входящие записи из нашего приложения и используем идентификатор пользователя (в виде...
Консольные команды kafka-console-producer.sh и kafka-console-consumer.sh работают правильно, но...
У меня есть поток данных, например: DataStream[myTuple(topic, value)] И я хотел отправить...
Когда я загружаю файл .jar в Spark, у меня появляется следующая ошибка: Exception in thread...