-
按照 实时功能使用文档启动了example里边realtime的case并且配置了kafka集群地址; kafka的分区数设置为1,因此应该不存在分区hash不对的问题,推送到kafka的方式是通过spring kafkaTemplate推送 |
Beta Was this translation helpful? Give feedback.
Replies: 3 comments 3 replies
-
先看下ha3.log中是否打印了日志"kafka reader init succuss",确保reader正常初始化了 |
Beta Was this translation helpful? Give feedback.
-
java里特殊字符需要这样传递: |
Beta Was this translation helpful? Give feedback.
-
发送消息的时候需要指定消息的key,否则校验的时候key为null会被过滤掉 |
Beta Was this translation helpful? Give feedback.
java里特殊字符需要这样传递:
行末:message.append("CMD=add\u001F\n");
结尾:message.append("\u001E\n");