fix

Pyspark_job/my_kafka/keyword_pcp_listener.py

@@ -17,7 +17,7 @@ def handle_listen(checkpoint):
         "kafka.sasl.jaas.config": """org.apache.kafka.common.security.plain.PlainLoginModule required username="consumer" password="J2#aLmPq7zX";""",
         "kafka.sasl.mechanism": "PLAIN",
         "kafka.security.protocol": "SASL_PLAINTEXT",
-        "kafka.bootstrap.servers": "61.145.136.61:19092,61.145.136.61:29092,61.145.136.61:39092",
+        "kafka.bootstrap.servers": "192.168.10.218:9092,192.168.10.219:9092,192.168.10.220:9092",
         "subscribe": topic_name,
         "failOnDataLoss": "false",
         "startingOffsets": "earliest",