>source

msg:b'\x04{"origin": "fluentd", "timestamp": "2021-12-18T01:21:17.683Z", "collected_at": "2021-12-18T01:21:17.683Z"}'

apache_beam.io.kafka(Apache Beam 2.30)에서 발생합니다. 파이썬 API.

원인은 무엇입니까?

안녕하세요, 흥미롭습니다. 아마도 b'\x04 표기법이 어떤 이유로 인식되지 않습니까?

jspcal2021-12-18 02:00:18

두 번 직렬화하는 것 같습니다.

fukanchik2021-12-18 02:05:37
  • 이전 parsing : 처음 n개 문자에 대해 파서를 n번 적용(Haskell)
  • 다음 excel : 여러 If/Then 호출 옵션