Я отправляю пустую матрицу от производителя kafka, и она отлично работает:
async def kafka_send(kafka_producer, data, topic):
test = np.array([[1, 2], [3, 4]])
x_enc = msgpack.packb(test, default=m.encode)
encoded = base64.encodebytes(x_enc)
await kafka_producer.send(topic, encoded)
С другой стороны, если я пытаюсь отправить этот код из преобразованного изображения в numpy, это неотправьте что-нибудь:
image = Image.open(io.BytesIO(post_data))
arr = np.asarray(image)
У кого-нибудь есть это?