Move to contants and settings.py

.env

@@ -2,4 +2,6 @@ DEBUG=True
 DATABASE_NAME = 'django-kafka'
 DATABASE_USER = ''
 DATABASE_PASSWORD = ''
-HOST_ENDPOINT = '127.0.0.1'
+HOST_ENDPOINT = '127.0.0.1'
+SCHEMA_REGISTRY_URL = 'http://localhost:8081'
+SECRET_KEY = 'gc97l0(yyw(^)bwezc)#^3ir5+!@z1%x18&fs9r%e-q^+ziq0e'

django_kafka/settings.py

@@ -1,22 +1,11 @@
 import os
 from decouple import config
 
-CELERY_TIMEZONE = 'Europe/Warsaw'
-# Let's make things happen
-CELERY_BEAT_SCHEDULE = {
- 'poll-every-second': {
-       'task': 'receive',
-       'schedule': 1.0,
-    }
-}
-
 BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
 
-SECRET_KEY = 'gc97l0(yyw(^)bwezc)#^3ir5+!@z1%x18&fs9r%e-q^+ziq0e'
-
-DEBUG = True
+SECRET_KEY = config('SECRET_KEY')
 
-ALLOWED_HOSTS = []
+DEBUG = config('DEBUG', default=False, cast=bool)
 
 INSTALLED_APPS = [
     'django.contrib.admin',
@@ -30,7 +19,8 @@
 ]
 ALLOWED_HOSTS = ['*']
 
-CELERY_BROKER_URL = 'redis://localhost:6379'
+CELERY_BROKER_URL = 'amqp://127.0.0.1:5672'
+SCHEMA_REGISTRY_URL = config('SCHEMA_REGISTRY_URL')
 
 MIDDLEWARE = [
     'django.middleware.security.SecurityMiddleware',

publish_subscribe/constants.py

@@ -16,4 +16,6 @@
       },
       "required": [ "username", "data" ]
     }
-    """
+    """
+
+USER_TOPIC = 'leon'

publish_subscribe/consumer.py

@@ -1,7 +1,7 @@
 from confluent_kafka import DeserializingConsumer
 from confluent_kafka.schema_registry.json_schema import JSONDeserializer
 from confluent_kafka.serialization import StringDeserializer
-from .constants import USER_SCHEMA
+from .constants import USER_SCHEMA, USER_TOPIC
 from .transformers import dict_to_user
 import logging
 import traceback
@@ -17,7 +17,7 @@ def receive():
                      'auto.offset.reset': "earliest"}
 
     consumer = DeserializingConsumer(consumer_conf)
-    consumer.subscribe(['leon'])
+    consumer.subscribe([USER_TOPIC])
 
     """
     The idea is to start the Kafka consumer when the message is sent to the Kafka producer.

publish_subscribe/producers.py

@@ -3,11 +3,13 @@
 from confluent_kafka.serialization import StringSerializer
 from confluent_kafka.schema_registry import SchemaRegistryClient
 from confluent_kafka.schema_registry.json_schema import JSONSerializer
-from .constants import USER_SCHEMA
+
+from django_kafka.settings import SCHEMA_REGISTRY_URL
+from .constants import USER_SCHEMA, USER_TOPIC
 from .transformers import user_to_dict
 from .models import UserProducer
 
-schema_registry_conf = {'url': 'http://localhost:8081'}
+schema_registry_conf = {'url': SCHEMA_REGISTRY_URL}
 schema_registry_client = SchemaRegistryClient(schema_registry_conf)
 
 
@@ -31,5 +33,5 @@ def send(username, data, token):
                         data=data,
                         token=token)
 
-    producer.produce(topic='leon', key=str(uuid4()), value=user,
+    producer.produce(topic=USER_TOPIC, key=str(uuid4()), value=user,
                      on_delivery=delivery_report)