[Question] Invitation to Join Beam Slack Channel

2023-02-13 Thread Leonardo Reis
Hi, I would like to learn more by joining the Beam Slack Channel. But it seems I can't join with my personal email and I don't have the @apache.org email either. I would like to ask if I can get invited to the Slack channel, or maybe there is another way to join? Thanks! Regards

[Go SDK] Error transforming byte array message from kafka inside ParDo

2023-06-06 Thread Leonardo Reis
element it receives. func (fn *LogFn) ProcessElement(elm []byte) { log.Infof(context.Background(), "Ride info: %v", elm) } // FinishBundle waits a bit so the job server finishes receiving logs. func (fn *LogFn) FinishBundle() { time.Sleep(2 * time.Second) } Could anyone help me with this error? Thanks a lot. Leonardo Reis.