Скажем, например - название темы Kafka - topic_X topic_X имеет 500 разделов в брокере Kafka Теперь мы установили 500 потребителей для группы Consumer_X для обработки каждого раздела. Куда Бежать этим 500 потребителям? В одной машине 500 ниток?...

Я пытаюсь получить сообщения из темы kafka в Amazon MSK (Kafka Version 2.2.1) с помощью процессора NiFi ConsumeKafka_2_6 (NiFi версии 1.12.1). В процессоре ConsumeKafka я получаю предупреждение как org.apache .kafka.clients.NetworkClient [Consumer...

Мы планируем использовать сервис AWS MSK для Managed Kafka и Schema Registry, а также сервисы Kafka Connect из Confluent вместе для запуска наших коннекторов (Elasticsearch Sink Connector). Мы планировали запустить реестр схем и коннекторы в EC2....

Если вы выполните следующую команду aws, вы получите сведения о кластере msk kafka: aws kafka list-clusters Это возвращает что-то вроде этого: { "ClusterInfoList": [ { "BrokerNodeGroupInfo": {...

Есть ли информация о том, как использовать данные AWS MSK в моем приложении Spring Cloud Stream? Я считаю, что нам нужно создать хранилище ключей и хранилище доверенных сертификатов, а затем включить их в наше приложение? Я просмотрел страницу...

Наш кластер AWS MSK не создает темы автоматически, когда производитель впервые публикует сообщение по теме. Это удивительно, поскольку поведение по умолчанию согласно https://kafka.apache.org/documentation/#brokerconfigs должен иметь...