in PythonKafkaSink/main.py [0:0]
def app_properties():
file_path = '/etc/flink/application_properties.json'
if os.path.isfile(file_path):
with open(file_path, 'r') as file:
contents = file.read()
print('Contents of ' + file_path)
print(contents)
properties = json.loads(contents)
return properties
else:
print('A file at "{}" was not found'.format(file_path))