Я разработал потребителя Kafka на python, используя библиотеку python-kafka на моем локальном компьютере. Мне нужно прочитать более 100 тем. Я использовал многопроцессорный модуль для создания пула рабочих для чтения тем и записи в базу данных.
У меня есть экземпляр EC2, и мне нужно знать, как лучше масштабировать мое приложение ??
Как читать темы параллельно ...