msgframe的kafka测试代码

ipu-kafka-example/src/main/java/com/ai/ipu/example/kafka/KafkaProducerExample.java

            final MsgFTextMessage message = new MsgFTextMessage();
            message.setText(text);
            client.sendOrderMsg(topic, message, orderId);
            LOG.debug("Sent:" + message);
            Thread.currentThread().sleep(1000);
        } catch (Exception e) {
            throw new RuntimeException(e);