You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
KAFKA_BROKERS "(required) kafka brokers"
KAFKA_DEFAULT_TOPIC "(optinal) default topic"
KAFKA_DEFAULT_PARTITION_KEY "(optianl) default partition key"
KAFKA_DEFAULT_MESSAGE_KEY "(optianl) default message key"
KAFKA_OUTPUT_DATA_TYPE "(optianl) output data type: json|ltsv|msgpack"
KAFKA_MAX_SEND_RETRIES "(optianl) the number of times to retry sending of messages to a leader, default is 1"
KAFKA_REQUIRED_ACKS "(optianl) the number of acks required per request, default is -1"
KAFKA_ACK_TIMEOUT "(optianl) how long the producer waits for acks, unit is seconds"
The text was updated successfully, but these errors were encountered:
RT,只看到以下几项环境变量
KAFKA_BROKERS "(required) kafka brokers"
KAFKA_DEFAULT_TOPIC "(optinal) default topic"
KAFKA_DEFAULT_PARTITION_KEY "(optianl) default partition key"
KAFKA_DEFAULT_MESSAGE_KEY "(optianl) default message key"
KAFKA_OUTPUT_DATA_TYPE "(optianl) output data type: json|ltsv|msgpack"
KAFKA_MAX_SEND_RETRIES "(optianl) the number of times to retry sending of messages to a leader, default is 1"
KAFKA_REQUIRED_ACKS "(optianl) the number of acks required per request, default is -1"
KAFKA_ACK_TIMEOUT "(optianl) how long the producer waits for acks, unit is seconds"
The text was updated successfully, but these errors were encountered: