function addStandardKafkaOptions(cmd) {
  cmd
    .option('--kafka-broker-list <broker-list>', 'List of kafka brokers endpoints')
    .option('--kafka-client-id <client-id>')
    .option('--kafka-consumer-group <consumer-group-id>')
    .option('--kafka-connection-timeout <connection-timeout>', 'Time in milliseconds to wait for a sucessful connection', (c) => parseInt(c), 3000)
    .option('--kafka-request-timeout <request-timeout>', 'Time in milliseconds to wait for a successful request', (c) => parseInt(c), 30000)
    .option('--kafka-max-retry-time <max-retry-time>', 'Max wait time for a retry in milliseconds', (c) => parseInt(c), 30000)
    .option('--kafka-initial-retry-time <retry-time>', 'Initial value used to calculate retry in milliseconds', (c) => parseInt(c), 300)
    .option('--kafka-max-retries <max-retries>', 'Max number of retries per call', (c) => parseInt(c), 5)
    .option('--kafka-metadata-max-age <metadata-max-age>', 'The period of time in milliseconds after which we force a refresh of metadata', (c) => parseInt(c), 300000)
    .option(
      '--kafka-transaction-timeout <transaction-timeout>',
      'The maximum amount of time in ms that the transaction coordinator will wait for a transaction status update from the produce',
      (c) => parseInt(c),
      60000
    )
    .option('--kafka-max-in-flight-reqeusts <max-in-flight-request>', 'Max number of requests that may be in progress at any time. If falsey then no limit', (c) => parseInt(c), 0)
    .option('--kafka-session-timeout <session-timeout>', 'Timeout in milliseconds used to detect failures.', (c) => parseInt(c), 30000)
    .option(
      '--kafka-rebalance-timeout <rebalance-timeout>',
      'The maximum time that the coordinator will wait for each member to rejoin when rebalancing the group',
      (c) => parseInt(c),
      60000
    )
    .option('--kafka-heartbeat-interval <heartbeat-interval>', 'The expected time in milliseconds between heartbeats to the consumer coordinator.', (c) => parseInt(c), 3000)
    .option('--kafka-max-bytes-per-partition <max-bytes-per-partition>', 'The maximum amount of data per-partition the server will return.', (c) => parseInt(c), 1048576)
    .option('--kafka-min-bytes <min-bytes>', 'Minimum amount of data the server should return for a fetch request.', (c) => parseInt(c), 1)
    .option('--kafka-max-bytes <max-bytes>', 'Maximum amount of bytes to accumulate in the response.', (c) => parseInt(c), 10485760)
    .option(
      '--kafka-max-wait-time <max-wait-time>',
      'The maximum amount of time in milliseconds the server will block before answering the fetch request if there isn’t sufficient data to immediately satisfy the requirement given by minBytes',
      (c) => parseInt(c),
      5000
    );
  return cmd;
}
/**
 * Add standard kafka options
 * @param {commander} cmd
 */
Add standard kafka options
@param {commander} cmd
Add standard kafka options @param { commander } cmd
function addStandardKafkaOptions(cmd) {
  cmd
    .option('--kafka-broker-list <broker-list>', 'List of kafka brokers endpoints')
    .option('--kafka-client-id <client-id>')
    .option('--kafka-consumer-group <consumer-group-id>')
    .option('--kafka-connection-timeout <connection-timeout>', 'Time in milliseconds to wait for a sucessful connection', (c) => parseInt(c), 3000)
    .option('--kafka-request-timeout <request-timeout>', 'Time in milliseconds to wait for a successful request', (c) => parseInt(c), 30000)
    .option('--kafka-max-retry-time <max-retry-time>', 'Max wait time for a retry in milliseconds', (c) => parseInt(c), 30000)
    .option('--kafka-initial-retry-time <retry-time>', 'Initial value used to calculate retry in milliseconds', (c) => parseInt(c), 300)
    .option('--kafka-max-retries <max-retries>', 'Max number of retries per call', (c) => parseInt(c), 5)
    .option('--kafka-metadata-max-age <metadata-max-age>', 'The period of time in milliseconds after which we force a refresh of metadata', (c) => parseInt(c), 300000)
    .option(
      '--kafka-transaction-timeout <transaction-timeout>',
      'The maximum amount of time in ms that the transaction coordinator will wait for a transaction status update from the produce',
      (c) => parseInt(c),
      60000
    )
    .option('--kafka-max-in-flight-reqeusts <max-in-flight-request>', 'Max number of requests that may be in progress at any time. If falsey then no limit', (c) => parseInt(c), 0)
    .option('--kafka-session-timeout <session-timeout>', 'Timeout in milliseconds used to detect failures.', (c) => parseInt(c), 30000)
    .option(
      '--kafka-rebalance-timeout <rebalance-timeout>',
      'The maximum time that the coordinator will wait for each member to rejoin when rebalancing the group',
      (c) => parseInt(c),
      60000
    )
    .option('--kafka-heartbeat-interval <heartbeat-interval>', 'The expected time in milliseconds between heartbeats to the consumer coordinator.', (c) => parseInt(c), 3000)
    .option('--kafka-max-bytes-per-partition <max-bytes-per-partition>', 'The maximum amount of data per-partition the server will return.', (c) => parseInt(c), 1048576)
    .option('--kafka-min-bytes <min-bytes>', 'Minimum amount of data the server should return for a fetch request.', (c) => parseInt(c), 1)
    .option('--kafka-max-bytes <max-bytes>', 'Maximum amount of bytes to accumulate in the response.', (c) => parseInt(c), 10485760)
    .option(
      '--kafka-max-wait-time <max-wait-time>',
      'The maximum amount of time in milliseconds the server will block before answering the fetch request if there isn’t sufficient data to immediately satisfy the requirement given by minBytes',
      (c) => parseInt(c),
      5000
    );
  return cmd;
}
function addStandardKafkaOptions ( cmd ) { cmd . option ( '--kafka-broker-list <broker-list>' , 'List of kafka brokers endpoints' ) . option ( '--kafka-client-id <client-id>' ) . option ( '--kafka-consumer-group <consumer-group-id>' ) . option ( '--kafka-connection-timeout <connection-timeout>' , 'Time in milliseconds to wait for a sucessful connection' , ( c ) => parseInt ( c ) , 3000 ) . option ( '--kafka-request-timeout <request-timeout>' , 'Time in milliseconds to wait for a successful request' , ( c ) => parseInt ( c ) , 30000 ) . option ( '--kafka-max-retry-time <max-retry-time>' , 'Max wait time for a retry in milliseconds' , ( c ) => parseInt ( c ) , 30000 ) . option ( '--kafka-initial-retry-time <retry-time>' , 'Initial value used to calculate retry in milliseconds' , ( c ) => parseInt ( c ) , 300 ) . option ( '--kafka-max-retries <max-retries>' , 'Max number of retries per call' , ( c ) => parseInt ( c ) , 5 ) . option ( '--kafka-metadata-max-age <metadata-max-age>' , 'The period of time in milliseconds after which we force a refresh of metadata' , ( c ) => parseInt ( c ) , 300000 ) . option ( '--kafka-transaction-timeout <transaction-timeout>' , 'The maximum amount of time in ms that the transaction coordinator will wait for a transaction status update from the produce' , ( c ) => parseInt ( c ) , 60000 ) . option ( '--kafka-max-in-flight-reqeusts <max-in-flight-request>' , 'Max number of requests that may be in progress at any time. If falsey then no limit' , ( c ) => parseInt ( c ) , 0 ) . option ( '--kafka-session-timeout <session-timeout>' , 'Timeout in milliseconds used to detect failures.' , ( c ) => parseInt ( c ) , 30000 ) . option ( '--kafka-rebalance-timeout <rebalance-timeout>' , 'The maximum time that the coordinator will wait for each member to rejoin when rebalancing the group' , ( c ) => parseInt ( c ) , 60000 ) . option ( '--kafka-heartbeat-interval <heartbeat-interval>' , 'The expected time in milliseconds between heartbeats to the consumer coordinator.' , ( c ) => parseInt ( c ) , 3000 ) . option ( '--kafka-max-bytes-per-partition <max-bytes-per-partition>' , 'The maximum amount of data per-partition the server will return.' , ( c ) => parseInt ( c ) , 1048576 ) . option ( '--kafka-min-bytes <min-bytes>' , 'Minimum amount of data the server should return for a fetch request.' , ( c ) => parseInt ( c ) , 1 ) . option ( '--kafka-max-bytes <max-bytes>' , 'Maximum amount of bytes to accumulate in the response.' , ( c ) => parseInt ( c ) , 10485760 ) . option ( '--kafka-max-wait-time <max-wait-time>' , 'The maximum amount of time in milliseconds the server will block before answering the fetch request if there isn’t sufficient data to immediately satisfy the requirement given by minBytes', ( c ) => parseInt ( c ) , 5000 ) ; return cmd ; }
Add standard kafka options
 @param {commander} cmd
Add standard kafka options @param { commander } cmd