...
|
...
|
@@ -22,7 +22,7 @@ public class KafakTest { |
|
|
@Test
|
|
|
public void kafakTest() throws Exception {
|
|
|
System.out.println("++++======");
|
|
|
kafkaTemplate.sendDefault("{\"uid\":\"8040768\",\"ts\":\"1492570964462\",\"param\":{\"C_ID\":\"1\",\"ORD_NUM\":\"170113812\"},\"os\":\"iPhone OS\",\"op\":\"YB_SC_ORD\",\"imei\":\"1b4747946de0c62\",\"udid\":\"1b4747946de0c624d348c57187cd7b02eb4126e0\",\"ip\":\"117.136.88.1\",\"idfa\":\"E65BC03A-6572-4B83-9706-D16BBFEAE51C\"}");
|
|
|
kafkaTemplate.sendDefault("{\"uid\":\"20000740\",\"ts\":\"1492570964462\",\"param\":{\"C_ID\":\"1\",\"ORD_NUM\":\"170129416\"},\"os\":\"iPhone OS\",\"op\":\"YB_SC_ORD\",\"imei\":\"1b4747946de0c62\",\"udid\":\"1b4747946de0c624d348c57187cd7b02eb4126e0\",\"ip\":\"117.136.88.1\",\"idfa\":\"E65BC03A-6572-4B83-9706-D16BBFEAE51C\"}");
|
|
|
|
|
|
Thread.sleep(300 * 1000);
|
|
|
}
|
...
|
...
|
|