Я могу производить / потреблять сообщения без каких-либо ошибок изнутри kubernetes Но я не могу...
Я хочу использовать пользовательский раздел в kafka с помощью приложения .net. Я создал тему,...
Есть ли способ приостановить или подавить производителя Kafka на основе отставания потребителей или...
Сводка TLDR: движок Clickhouse Kafka, материализованное представление не будет работать со сложным...
Я хочу переназначить разделы в Kafka при масштабировании в / масштабе вне узлов, развернутых в...
У меня есть следующий вариант использования - из набора avro-контрактов - определенный как файлы
У меня есть тема, которая используется двумя группами потребителей. В теме 10 сообщений. Приложение...
По умолчанию Kafka отправляет сообщения из темы всем группам потребителей. В моем случае у меня...
Мне нужно написать Java-код, чтобы пользователь kafka мог потреблять сообщения. После того, как...
Меня интересует, что происходит, когда Logstash не может отправлять события в выходной пункт...
Я занимаюсь разработкой микросервиса, который использует сообщения от Kaffka, затем обрабатывает...
Я использую поток Кафки, где моим значением является HashMap. Для этого мне нужно создать SerDe для...
Я хотел знать, что эквивалентно теме кафки, когда я хочу использовать вместо этого Kinesis...
У нас работают 5 рабочих на разных узлах, и мы запускаем соединитель со следующими конфигами: tasks
Я бы хотел визуализировать поток Кафки с помощью Unity3D. Какой лучший способ получить доступ к...
Я работаю над Spring Boot 2.1.1, который должен общаться с Кафкой В таком состоянии приложение...
Невозможно записать сообщение в тему kafka (продюсер) при вызове kakfa производить класс с циклом....
В эти дни я изучаю микросервисную архитектуру, и мне нужно запустить Kafka, чтобы следовать...
При использовании кафки я хочу получить смещение раздела. Однако, когда я вызываю позицию, я...
On-прем ---> HAProxy (AWS) ---> Кафка (AWS). Мы можем разрешить внешнее общение, используя свойство...
Мы хотим добавить аутентификацию в наш кластер kafka с помощью SASL. Как мы видим, мы хотим иметь...
Я пытаюсь реализовать сценарий «Точно однажды». используя транзакции. properties
Kafka кластер с 3 брокерами (версия: 1.1.0) и хорошо работает более 6 месяцев. Затем мы изменили...
Пожалуйста, различайте лидера Кафки (брокера) и лидера раздела. Лидер раздела может также...
Я использую версию kafka 2.0 со scala, некоторые из apis устарели во второй версии. Ниже Это...