Mageshkumar-C opened a new issue, #34894: URL: https://github.com/apache/beam/issues/34894
im using readfromkafka inbuilt method to read the kafka messages in python for my usecase . But im getting handshake failed error and multiple other errors as well while testing in local as well as dataflow. Previously i was using custom function to read the kafka messages using while loop. at that time everything was working fine.i just modified readfromkafka to read the messages .suddenly im getting the errors. Since im having high throughput custom read is not helpful .so help me to fix this issue in python. Thanks, -- 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: github-unsubscr...@beam.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
