报错 下标越界

Question

在kafka对接streaming 使用producer 进行测试的时候，若生产者输入referer为空的一条日志就正常，可以正常解析

若在生产端输入带网址的：128.187.36.27 2018-08-21 22:47:59 "GET /class/128.html HTTP/1.1" 200 https://search.yahoo.com/search?p=hadoop 基础，就报错，

对应的报错代码是 这里

测试了，没找到原因

同样的代码内容，同样的测试log，用RDD就能解析出来，放到streaming里测试就是下标越界

Answer 1

Michael_PK 2018-08-24 10:57:31

数组下标越界了！！！  很简单，你把生产的这个完整信息，拷贝出来，写个测试类解析下，肯定是字符串截取的有问题

• 提问者 人唯优2018 #1

  同样的代码内容，同样的测试log，用RDD就能解析出来，放到streaming里测试就是下标越界

• 提问者 人唯优2018 #2

  解决了老师，糊涂了 是之前写进去一个没有换行的缘故，重开了个topic就好了

• Michael_PK 回复 提问者 人唯优2018 #3

  细节决定成败，哈哈