Эффективная стратегия, позволяющая избежать дублирования сообщений в Apache Kafka.

Ни один из упомянутых ответов не работал для меня, поэтому я опубликую свой способ решить эту проблему. Я использую следующий скрипт at the beginning of my main.py, и он отлично работает.

Используйте следующее, как есть (скопируйте его):

import numpy as np
import . . . . . . . 

def warn(*args, **kwargs):
    pass
import warnings
warnings.warn = warn

# more code here...
# more code here...