producer

0зной

1ответ

У меня есть несколько вопросов о Кафке. Если кто-то может мне помочь, отвечая на одного из них, я буду очень благодарен. Спасибо заранее :) Q1) Я знаю, что разделы разбиты на Кафка Брокер. Но раскол о

4зной

1ответ

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

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

0зной

1ответ

Kafka ssl Производитель EOFException в то время как Producer.send от облачного литейного цеха

В облачном литейном я могу создать сообщение для не ssl url ("kafkaURL: 9092"). Но он НЕ работает для ssl url («kafkaURL: 9093»). Версия сервера Kafka 0.10.0.1 и версия клиента 0.10.0.0. Вот свойство

0зной

1ответ

tensorflow.train.string_producer ничего не возвращает

Я тренирую свои собственные данные изображений с использованием модели cifar-10 cnn, информация об отладке ниже. место отладки: # Create a queue that produces the filenames to read. filename_qu

0зной

1ответ

Fink: Потеря данных KafkaProducer

Наш потоковый поток Flink публикует сообщения в Kafka. Механизм «повторения» KafkaProducer не срабатывает до тех пор, пока в его внутренний буфер не добавится сообщение. Если перед этим существует иск

0зной

1ответ

Использование прокси для ввода с помощью CDI Producer

Я попытался выполнить некоторые из предложений, которые я нашел в ранее опубликованных вопросах, но я не могу получить полное решение. Используя следующий код: @Produces @Dependent @RestClientResour