i have 0.8.1 producer/consumer... I start producer first but when i start consumer i see the following :
Apr 15 21:26:29 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|main.go:34|2015/04/15 21:26:29|Starting ConsumerService Apr 15 21:26:29 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|main.go:47|2015/04/15 21:26:29|Influxdb client created:11.1.75.1:8086 db=logging Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:145|2015/04/15 21:26:30|No of partitions are:20 Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:343|2015/04/15 21:26:30|curPartitions:[3 2 1 0 5 4] Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:354|2015/04/15 21:26:30|Used=3 true Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:354|2015/04/15 21:26:30|Used=2 true Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:354|2015/04/15 21:26:30|Used=1 true Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:354|2015/04/15 21:26:30|Used=0 true Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:354|2015/04/15 21:26:30|Used=5 true Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:354|2015/04/15 21:26:30|Used=4 true Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:359|2015/04/15 21:26:30|Used[6]=false Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:184|2015/04/15 21:26:30|Availalbe partition index is:6 Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:221|2015/04/15 21:26:30|Offsetvalue is:106948 Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:238|2015/04/15 21:26:30|msgQ consumer initialization ready Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:145|2015/04/15 21:26:30|No of partitions are:20 Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:343|2015/04/15 21:26:30|curPartitions:[2 1 0] Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:354|2015/04/15 21:26:30|Used=2 true Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:354|2015/04/15 21:26:30|Used=1 true Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:354|2015/04/15 21:26:30|Used=0 true Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:359|2015/04/15 21:26:30|Used[3]=false Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:184|2015/04/15 21:26:30|Availalbe partition index is:3 Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:221|2015/04/15 21:26:30|Offsetvalue is:1065377 Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: INFO|10cf22c161e3|1|consumer|msgq.go:238|2015/04/15 21:26:30|msgQ consumer initialization ready Apr 15 21:26:30 node-1cc1de6d1224 docker[32360]: ERROR|10cf22c161e3|1|consumer|main.go:82|2015/04/15 21:26:30|Unable to Receive Message:kafka server: The requested offset is outside the range of offsets maintained by the server for the given topic/partition. The offset in zookeeper is 200, so where's Offsetvalue :1065377 coming from and how can i reset it? I see the same problem even if I delete/re-create topics before I try to start producer/consumer pair Than you
