При использовании django-logpipe я получаю эту ошибку "logpipe.exceptions.MissingTopicError"

Question

Я запускаю местного производителя kafka для создания сообщений и создал для него тему "test_topic".Здесь я включил настройки logpipe в settings.py моего проекта Django. Я также упомянул сервер начальной загрузки как мой локальный компьютер

#LOGPIPE SETTINGS in settings.py:

INSTALLED_APPS = [
  'django.contrib.admin',
  'django.contrib.auth',
  'django.contrib.contenttypes',
  'django.contrib.sessions',
  'django.contrib.messages',
  'django.contrib.staticfiles',
  'logpipe',
]
LOGPIPE = {
  # Required Settings
  'OFFSET_BACKEND': 'logpipe.backend.kafka.ModelOffsetStore',
  'CONSUMER_BACKEND': 'logpipe.backend.kafka.Consumer',
  'PRODUCER_BACKEND': 'logpipe.backend.kafka.Producer',
  'KAFKA_BOOTSTRAP_SERVERS': [
      'localhost:9092'
  ],
  'KAFKA_CONSUMER_KWARGS': {
      'group_id': 'django-logpipe',
  },

  # Optional Settings
  # 'KAFKA_SEND_TIMEOUT': 10,
  # 'KAFKA_MAX_SEND_RETRIES': 0,
  # 'MIN_MESSAGE_LAG_MS': 0,
  # 'DEFAULT_FORMAT': 'json',
}