module Kafkat::Interface