I am using Kafka 10.0 and https://github.com/Shopify/sarama. I am trying to get the offset of the latest message that a consumer processed. To do so I've found the method NewOffsetManagerFromClient(group string, client Client) which require the group name. How do…
Now that Golang Kafka library (sarama) is providing consumer group capability without any external library help with kafka 10. How can I get the current message offset being processed by a consumer group at any given time ? Previously I…
I've worked with Go for a while now and has yet to really nail how I work with errors. Even the standard library has a number of different ways to deal with errors (some not even making it possible to…
I know I need to use a time layout in Go (as shown here https://golang.org/src/time/format.go) but I can't find the layout for an ISO 8601 timestamp. If it helps, I get the timestamp from the Facebook API. Here is an…
I'm getting coordinates (location) as an output of 2 float64 numbers, and it looks like this: &{%!s(float64=42.539679) %!s(float64=42.601339)} This is the first time I'm seeing anything like that, so what is "%!s"? "TypeOf" says "%!s(float64=42.539679)" is float64. So how do…
I'm creating a small service where I poll around 100 accounts (in a Twitter-like service) frequently (every 5 seconds or so) to check for new messages, as the service doesn't yet provide a streaming API (like Twitter actually does). In…
I want to build an API based application using GO and MongoDB. I'm from Asp.net MVC background. Probably if I make an architecture with MVC web application things to be consider are Separation of concerns(SoC) DataModel BusinessEntities BusinessServices Controllers Dependeny…