Результаты поиска по запросу "apache-kafka"

7 ответов

Windows, но я также проверил его на Linux, и он работал.

способ протестировать приложение Kafka Streams. Чтобы я мог определить входные события, а набор тестов показывает мне вывод.Это возможно без реальной настрой...

2 ответа

Оооо ... Я запомню это.

1 ответ

Кроме того, если вы создаете темы заранее или запускаете производителя раньше потребителя, такое поведение не должно происходить вообще.

ТОП публикаций

3 ответа

Единственное преимущество, которое я могу придумать, это транзакционная функция, остальное можно сделать с помощью Kafka.

попросили оценить RabbitMQ вместо Kafka, но мне было трудно найти причину, по которой он делает что-то лучше, чем Kafka. Кто-нибудь знает, действительно ли о...

0 ответов

Вам нужно будет обрабатывать сжатые логические изменения - например, на операции обновления / удаления? Как вы будете решать это на стороне потребителя?

1 ответ

Я встретил ту же проблему и решил ее в соответствии с вашим ответом. Спасибо.

я возникла ситуация, когда spark может транслировать и получать сообщения только из одного раздела темы 2-patition Kafka.Мои темы:

1 ответ

Но увеличивает ли удаление, которое происходит в брокере Kafka, задержку между отправлением и получением сообщений? И если так, есть ли способ избежать этого?

ольно новичок в кафке, так что прости меня, если этот вопрос тривиален. У меня есть очень простая настройка для тестирования времени:Машина A -> пишет в т...

1 ответ

Каждая запись будет отправлена ​​каждому предикату один раз - это концептуально широковещательная рассылка всем фильтрам, но записи не будут физически реплицированы, поэтому нет никаких накладных расходов памяти.

я есть одна основная тема и несколько предикатов, с каждым из которых связана выходная тема. Я хочу отправить каждую запись во ВСЕ темы, чей предикат разреша...

1 ответ

 тема от Zookeeper и затем снова запуск кластера.

опытке использовать Kafka с помощью потребителя высокого уровня (с использованием совершенно новой группы потребителей) потребитель никогда не запускается. К...

1 ответ

Большое спасибо. Сработало после перехода на версию 2.11