Hello, I am following the example in Python Walkthrough <https://nightlies.apache.org/flink/flink-statefun-docs-release-2.0/getting-started/python_walkthrough.html#what-are-you-building>, I downloaded the zip file with the project skeleton. I'm having a problem when changing the key attribute in the function producer.send to none. From:
def produce(): if len(sys.argv) == 2: delay_seconds = int(sys.argv[1]) else: delay_seconds = 1 producer = KafkaProducer(bootstrap_servers=[KAFKA_BROKER]) for request in random_requests(): key = request.name.encode('utf-8') val = request.SerializeToString() producer.send(topic='names', key=key, value=val) producer.flush() time.sleep(delay_seconds) To: def produce(): if len(sys.argv) == 2: delay_seconds = int(sys.argv[1]) else: delay_seconds = 1 producer = KafkaProducer(bootstrap_servers=[KAFKA_BROKER]) for request in random_requests(): key = request.name.encode('utf-8') val = request.SerializeToString() producer.send(topic='names', key=None, value=val) producer.flush() time.sleep(delay_seconds) After doing this the consumer is not displaying anything. I modified python code so the message arrived is printed and it is not being printed here, I suppose that the problem could be a bad configuration in module.yaml file? I understand that by putting key=None the topic partition will be chosen randomly, that was the behaviour that I was aiming for as I do not need any ordering in the messages. Do I need any additional configuration in this walkthrough to achieve this? Thank you very much in advance.