Кафка Потоки Ровно Однажды Потребительские Группы - PullRequest
Новая
       6

Кафка Потоки Ровно Однажды Потребительские Группы

0 голосов
/ 22 апреля 2019

Когда я включаю ровно одну обработку, я получаю следующую ошибку. ПРИМЕЧАНИЕ. Наши приложения очень безопасны, и мы предоставляем пользователям и пользователям kafka только доступ к ресурсам, которые им явно необходимы. 

2019-04-22 15:28:09 INFO  (kafka.authorizer.logger)233 - Principal = User:xxx is Denied Operation = Describe from hos
xxx.xxx.xxx.xxx on resource = TransactionalId:application_consumer-0_16

При единовременной обработке потоки kafka используют группу потребителей для каждой задачи потока вместо группы потребителей во всех задачах потока?

1 Ответ

0 голосов
/ 23 апреля 2019

Если включен один раз, все еще есть только одна группа потребителей, такая же, как application.id.Однако вместо использования одного Producer на поток используется один производитель на задачу .

Вам необходимо разрешение на транзакцию.TransactionsId сообщения об ошибках от производителя задачи 0_16.Каждый производитель использует свой собственный идентификатор транзакции, который построен как <application.id>-<taskId>.

. Для получения подробной информации сравните документы: https://docs.confluent.io/current/kafka/authorization.html#using-acls

...