`dkafka` must provide the decoded `DbOp`. This must support the different format as for now JSON and Avro TDB specify how to get the DbOp