У нас есть требование слоя сообщения, и мы хотим, чтобы порядок сообщений сохранялся до тех пор, пока он не будет потреблен потребителем. Мы изучаем Кафку за то же самое. Я понимаю, что Kafka не гаран
Мы используем конфигурацию Java для производителя для достижения асинхронного механизма Retry и на стороне потребителя, мы используем сообщение приводимого адаптер (конфигурации XML). определить, что
Имейте базовый пример, который работает как шарм для 1 потребителя. Он получает сообщения. Но добавление одного дополнительного потребителя будет проигнорировано. let kafka = require('kafka-node');
l
При попытке использовать службу Message Hub Bluemix с confluent-kafka-python я получаю исключение ERROR Uncaught:, KafkaError {code = _INVALID_ARG , val = -186, str = "Нет такого свойства конфигурации
Наш потоковый поток Flink публикует сообщения в Kafka. Механизм «повторения» KafkaProducer не срабатывает до тех пор, пока в его внутренний буфер не добавится сообщение. Если перед этим существует иск