29 lines
662 B
Python
29 lines
662 B
Python
import json
|
|
|
|
|
|
class Config:
|
|
|
|
SUBSCRIBE_TOPIC = ['test', 'test2']
|
|
KAFKA_CONSUMER_CONF = {
|
|
'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"],
|
|
'value_deserializer': json.loads,
|
|
'group_id': 'ta2legu'
|
|
}
|
|
KAFKA_PRODUCER_CONF = {
|
|
'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"],
|
|
'value_serializer': lambda v: json.dumps(v).encode('utf-8'),
|
|
}
|
|
|
|
TOPIC_TO_LEGU = {
|
|
'a77703e24e6643d08b74a4163a14f74c': 'legu_test',
|
|
'c3e0409ac18341149877b08f087db640': 'legu_test'
|
|
}
|
|
|
|
|
|
|
|
class Debug(Config):
|
|
pass
|
|
|
|
|
|
settings = Debug
|