fmannhardt / graphql-kafka-subscriptions Goto Github PK

export interface IKafkaOptions {
  topic: string
  host: string
  port: string
  logger?: Logger,
  groupId?: any,
  globalConfig?: object,
  topicConfig?: object,
  useHeaders?: boolean,
  keyFun?: (any) => Buffer 
}

  brokerList(){
    return this.options.port ? `${this.options.host}:${this.options.port}` : this.options.host
  }