I found this embedded kafka example online (
https://gist.github.com/mardambey/2650743) which I am re-writing to work
with 0.8
Can someone help me re-write this portion:
val cons = new SimpleConsumer(localhost, 9090, 100, 1024)
var offset = 0L
var i = 0
while (true) {
val
Ok so now it is looping through the messages fine, and outputting the
actual message payload:
while (true) {
//val fetchRequest = new FetchRequest(TEST, 0, offset, 1024)
val fetchRequest = new FetchRequestBuilder().addFetch(topic, partition,
offset, 1024).build()
val fetchResponse:
