Tenho uma simples aplicação que pega uma mensagem do kafka e salva no db2 , por algum motivo estou obtendo o seguinte erro ao salvar:
Caused by: com.ibm.db2.jcc.am.SqlSyntaxErrorException: DB2 SQL Error: SQLCODE=-1667, SQLSTATE=42858, SQLERRMC=D_ODS_STREAM_PORTALONE.TR_RECEP;ORGANIZE BY COLUMN;FINAL|NEW|OLD TABLE, DRIVER=4.31.10
Segue minha classe de consumer:
/**
* Recebe a mensagem do EventHub da Azure utilizando Kafka
*/
@Component
@Slf4j
public class KafkaConsumer {
private final PortalONERepository portalONERepository;
private final ObjectMapper objectMapper;
@Autowired
public KafkaConsumer(PortalONERepository portalONERepository, ObjectMapper objectMapper) {
this.portalONERepository = portalONERepository;
this.objectMapper = objectMapper;
}
@KafkaListener(topics = "divout")
@Transactional("transactionManager")
public void consumeEventHubMessage(String consumerMessage) {
log.info("Received message from kafka queue: {}", consumerMessage);
//Convert string message to java object
try {
DocumentONE[] documentOne = objectMapper.readValue(consumerMessage, DocumentONE[].class);
//Salvar cada mensagem no db2
portalONERepository.saveAll(Arrays.asList(documentOne));
} catch (JsonProcessingException e) {
log.error("Error receiving message: " + e.getMessage());
}
}
}
O que poderia estar causando este erro?
insert
IDENTITY
na anotation da propriedade? não pode passar valor para uma coluna que éIDENTITY