私は助けが必要です。私はフィルタリングし、別のcsvファイルに書き込むことを試みています。このファイルは、加速度の大きさと共にelapsed_secondsカラムで10769年以降に収集されたデータで構成されています。しかし、私はKeyError例外を取得しています:私は取得しています0 ... import numpy as np
import pandas as pd
import mat
kafka-python apiを使ってトピックにたくさんのメッセージを送ります。成功したトピックに送信されますが、プログラムには、次のエラーメッセージを表示して終了する前にいないそれらのすべてが送信されたメッセージの一部: KeyError: <kafka.producer.record_accumulator.RecordBatch object at 0x143d290>
Batch is