Add diamond collector for monitoring storm-kafka offsets