imadmoussa1 opened a new issue, #22606: URL: https://github.com/apache/beam/issues/22606
### What happened? Hello, I was trying to use the WriteToKafka from apache_beam.io.kafka. Evrything in pipeline is working but when I added the WriteToKafka I have ` raise RuntimeError( RuntimeError: Service failed to start up with error 1 ` After checking the documentation I found that I need to use this because the Kafka in an extremal multi cross packages `python apache_beam/runners/portability/expansion_service_main.py -p 18089 --fully_qualified_name_glob "*"` while running this I have a different error: ` signal.pause() AttributeError: module 'signal' has no attribute 'pause'` can you help with this problem ? I am using beam 2.4.0 ### Issue Priority Priority: 0 ### Issue Component Component: io-py-kafka -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
