fixed bootstrap & parameterized private_ip

2019-10-02 11:33:24 -04:00 · 2019-10-02 11:33:24 -04:00 · 0c90e2048f
parent 8897c1f973
commit 0c90e2048f
1 changed files with 0 additions and 1 deletions
--- a/distroduce/messaging_sim.py
+++ b/distroduce/messaging_sim.py
@ -77,7 +77,6 @@ if __name__ == "__main__":
        policy_ops=[lambda a, b: a + b]
    )

-    # parmeterize localhost, PRIVATE_IP=`hostname -I | xargs`
    kafkaConfig = {'send_topic': 'test', 'producer_config': {'bootstrap_servers': f'{sys.argv[1]}:9092', 'acks': 'all'}}
    dist_proc_ctx = ExecutionContext(context=exec_mode.dist_proc, method=distributed_produce, kafka_config=kafkaConfig)
    run = Executor(exec_context=dist_proc_ctx, configs=configs, spark_context=sc)