Spring Boot внедряет ObjectMapper в Kafka JsonDeserializer

Когда вы используете двойные скобки, например

H3 = H2[['SOLD_PRICE']]

H3, становится DataFrame. Если вы используете одиночные скобки,

H3 = H2['SOLD_PRICE']

, то H3 становится серией. Если H3 является серией, то результат, который вы хотите, следует естественным образом:

import pandas as pd
import numpy as np
rng = pd.date_range('1/1/2011', periods=72, freq='M')
H2 = pd.DataFrame(np.arange(len(rng)), index=rng, columns=['SOLD_PRICE'])
H3 = H2['SOLD_PRICE']
H5 = H3.resample('Q', how='count')
H6 = pd.rolling_mean(H5,4)
print(H6.head())

дает

2011-03-31   NaN
2011-06-30   NaN
2011-09-30   NaN
2011-12-31     3
2012-03-31     3
dtype: float64
1
задан FlorianDe 6 March 2019 в 05:00
поделиться

1 ответ

Вам нужна отдельная фабрика потребителей / контейнеров для каждого слушателя. Затем используйте свойство containerFactory в @KafkaListener, чтобы указать используемую фабрику.

0
ответ дан Gary Russell 6 March 2019 в 05:00
поделиться
Другие вопросы по тегам:

Похожие вопросы: