Привет, я новичок в Kafka, и мне удалось запустить сервер Kafka в Windows (через терминал),...
У меня есть сценарий, когда мои сообщения кафки (из той же темы) проходят через один конвейер...
ОБНОВЛЕНИЕ: Я взглянул на упомянутый файл kafka.jar, который, кажется, добавляется в classpath...
У меня есть вопрос по поводу некоторого кода на python, который использует модуль kafka-python, и я...
Я хочу спросить о моей проблеме при установке клиента Confluent Golang Kafka в Mac OS Mojave....
Мне нужно создать kafkaAmdinClient объект SSL с использованием объекта java.security.keystore. Т.е....
У меня очень простой вариант использования.У меня есть один потребитель Kafka, и я хочу переместить...
Ошибка импорта в intellij import org.apache.spark.sql.avro ._ изображение: https://i.stack.imgur
Скажем, есть группа потребителей.(Потребители с одинаковым идентификатором группы). Группа...
Я настроил свой Kafka Connect с помощью Kerberized Kafka Cluster. (Скажем, KDC это "kafka-auth101
Я пытаюсь отправить сообщение размером 10770128 байт через Кафку.Я получаю следующую ошибку: org
Я установил AWS MSK, но у него нет графического интерфейса для просмотра конфигурации сервера.Я...
Интересно, что произойдет, если вы получите исключение из-за неудачной фиксации, потому что...
Мы уже более года используем реестр Confluent Schema с KafkaStreams, и все работает хорошо;до...
У меня есть десять производителей Kafka, каждый из которых пишет в разные разделы темы. Не могу...
Я получил требование подписаться на файлы сообщений в реальном времени, которые могут быть...
Используя версию 2.11-0.11.0.3 kafka для публикации 10000 сообщений (общий размер всех сообщений...
Я использую Apache Flink и пытаюсь подключиться к концентратору событий Azure, используя протокол...
Я пытаюсь настроить apache kafka в весенней загрузке приложения.Я читаю эту документацию и выполняю...
1) Я запускаю kafka на моей машине 2) Я запускаю свой весенний загрузочный сервер с конфигом: @Bean...
Извините за основной вопрос. Требование: необходимо отправить полезную нагрузку json из приложения...
Я использую Intellij Idea для разработки этого простого Java-приложения ниже. Когда я выполняю его...
Я пытаюсь обновить Kafka в академическом проекте и нашел этот класс в 0.8, который устарел в Kafka...
работает confluent-kafka 3.3.1e Kafka 0.11.0x У меня один раздел с репликами = 3. Мой производитель...
Я пытался установить Kafka с IntelliJ (в Windows), но IntelliJ не импортирует изменения.Я создаю...