Я пытаюсь воспроизвести рабочий трафик на тестовом экземпляре Kafka с помощью MirrorMaker. У меня...
у нас есть 5 брокеров kafka, фактор репликации 3 и 2 темы - T1 и T2. В теме T1 100 разделов, в T2 -...
Я работаю в инфраструктуре с Docker Swarm, где есть одна (и только) кафка на узел, все в порядке,...
Я не могу получить доступ к брокерам Kafka извне (с публичного IP-адреса). Я использую...
У меня есть сценарий использования, в котором я хочу записать изменения данных (вставка /...
Я пытаюсь выяснить, нужно ли мне включать фиксацию вручную с помощью KafkaConsumer.commitSync...
Я знакомлюсь с kafka и хочу узнать, как я могу использовать сообщения из разделов в теме для таблиц...
У меня есть топология Flink, которая использует ListState [MyAvroClass] в CoProcessFunction. В моей...
Я - Кафка для java-микросервисов с Streams, и мы также используем KeyValueStore для того, чтобы...
Я прошел урок от baeldung . Они упоминают, что есть два способа создания схемы. Написав...
У меня есть весеннее приложение, которое является моим производителем кафки, и мне было интересно,...
Может ли произойти следующая ситуация, когда я создаю получателя и немедленно вызываю consumer
У меня есть приложение Spring Boot, и оно должно обрабатывать некоторые потоковые данные Kafka. Я...
Средний размер сообщения невелик, но размер варьируется. Средний размер сообщения: 1 КБ 1Мбайт...
Установить информацию о kafka: Vmware установлен на сервере Windows 2016. Cent OS 7.1 установлена...
Каковы соответствующие значения для следующих свойств брокера Kafka для производственной системы?...
Мои товарищи по команде разрабатывают REST API с использованием Spring Boot + PostgreSQL + Redis +...
Я хотел бы иметь эффективную систему в реальном времени для выполнения оконных счетчиков событий в...
На сегодняшний день я либо использовал существующую профессиональную установку для Hadoop с...
Я пытаюсь разработать микросервис python, который может обрабатывать запросы REST API, а также...
В SB2 Brave обрабатывает сообщения Kafka с заголовками B3 по умолчанию, однако мне нужно изменить...
Я использую kafka-connect-jdbc-4.0.0.jar и postgresql-9.4-1206-jdbc41.jar конфигурация разъема...
Используя Apache Kafka 2.1.0 и spring-kafka 2.1.7, мы получаем сообщения об ошибках, подобные...
У меня есть Kafka, основанный на 3-х узлах, для зоопарка. Я использую версию 0.11.xx Недавно мы...
Я просто новичок Кафки и у меня проблема: У меня есть тема 'A' в Kafka, я запускаю загрузочное...