Transaction Sender options
Usage:
orchestrate tx-sender run [flags]
Flags:
--chain-registry-url string URL of the Chain Registry HTTP endpoint.
Environment variable: "CHAIN_REGISTRY_URL" (default "localhost:8081")
--checker-max-recovery int Maximum number of times tx-sender tries to recover an envelope with invalid nonce before outputing an error
Environment variable: "NONCE_CHECKER_MAX_RECOVERY" (default 5)
-h, --help help for run
--kafka-consumer-group-heartbeat-interval duration The expected time between heartbeats to the consumer coordinator when using Kafka's group management facilities. Heartbeats are used to ensure that the consumer's session stays active and to facilitate rebalancing when new consumers join or leave the group.
Environment variable: "KAFKA_CONSUMER_GROUP_HEARTBEAT_INTERVAL" in ms (default 3s)
--kafka-consumer-group-rebalance-strategy string Strategy for allocating topic partitions to members (one of ["Sticky" "Range" "RoundRobin"]).
Environment variable: "KAFKA_CONSUMER_GROUP_REBALANCE_STRATEGY" (default "Range")
--kafka-consumer-group-rebalance-timeout duration The maximum allowed time for each worker to join the group once a rebalance has begun. This is basically a limit on the amount of time needed for all tasks to flush any pending data and commit offsets. If the timeout is exceeded, then the worker will be removed from the group, which will cause offset commit failures
Environment variable: "KAFKA_CONSUMER_GROUP_REBALANCE_TIMEOUT" (default 1m0s)
--kafka-consumer-group-session-timeout duration The timeout used to detect consumer failures when using Kafka's group management facility. The consumer sends periodic heartbeats to indicate its liveness to the broker. If no heartbeats are received by the broker before the expiration of this session timeout, then the broker will remove this consumer from the group and initiate a rebalance.
Environment variable: "KAFKA_CONSUMER_GROUP_SESSION_TIMEOUT" (default 10s)
--kafka-consumer-max-processing-time duration The maximum amount of time the consumer expects a message takes to process for the user. If writing to the Messages channel takes longer than this, that partition will stop fetching more messages until it can proceed again.
Environment variable: "KAFKA_CONSUMER_MAXPROCESSINGTIME" (default 100ms)
--kafka-consumer-max-wait-time duration The maximum amount of time the broker will wait for Consumer.Fetch.Min bytes to become available before it returns fewer than that anyways.
Environment variable: "KAFKA_CONSUMER_MAX_WAIT_TIME" in ms (default 250ms)
--kafka-group string Address of Kafka server to connect to.
Environment variable: "KAFKA_GROUP" (default "group-e2e")
--kafka-sasl-enabled Whether or not to use SASL authentication when connecting to the broker
Environment variable: "KAFKA_SASL_ENABLED"
--kafka-sasl-handshake Whether or not to send the Kafka SASL handshake first if enabled (defaults to true). You should only set this to false if you're using a non-Kafka SASL proxy.
Environment variable: "KAFKA_SASL_HANDSHAKE" (default true)
--kafka-sasl-mechanism string SASLMechanism is the name of the enabled SASL mechanism. Possible values: OAUTHBEARER, PLAIN (defaults to PLAIN).
Environment variable: "KAFKA_SASL_MECHANISM"
--kafka-sasl-password string Password for SASL/PLAIN or SASL/SCRAM auth.
Environment variable: "KAFKA_SASL_PASSWORD"
--kafka-sasl-scramauthzid string Authz id used for SASL/SCRAM authentication
Environment variable: "KAFKA_SASL_SCRAMAUTHZID"
--kafka-sasl-user string Username for SASL/PLAIN or SASL/SCRAM auth.
Environment variable: "KAFKA_SASL_USER"
--kafka-tls-ca-cert-file string CA cert file Path.
Environment variable: "KAFKA_TLS_CA_CERT_FILE"
--kafka-tls-client-cert-file string Client Cert File Path.
Environment variable: "KAFKA_TLS_CLIENT_CERT_FILE"
--kafka-tls-client-key-file string Client key file Path.
Environment variable: "KAFKA_TLS_CLIENT_KEY_FILE"
--kafka-tls-enabled Whether or not to use TLS when connecting to the broker (defaults to false).
Environment variable: "KAFKA_TLS_ENABLED"
--kafka-tls-insecure-skip-verify Controls whether a client verifies the server's certificate chain and host name. If InsecureSkipVerify is true, TLS accepts any certificate presented by the server and any host name in that certificate. In this mode, TLS is susceptible to man-in-the-middle attacks. This should be used only for testing.
Environment variable: "KAFKA_TLS_INSECURE_SKIP_VERIFY"
--kafka-url strings URL (addresses) of Kafka server(s) to connect to.
Environment variable: "KAFKA_URL" (default [localhost:9092])
--kafka-version string The version of Kafka that Sarama will assume it is running against. Defaults to the oldest supported stable version. Since Kafka provides backwards-compatibility, setting it to a version older than you have will not break anything, although it may prevent you from using the latest features. Setting it to a version greater than you are actually running may lead to random breakage.
Environment variable: "KAFKA_CONSUMER_GROUP_REBALANCE_TIMEOUT" (default "1.0.0")
--nonce-manager-type string Type of Nonce (one of ["in-memory" "redis"])
Environment variable: "NONCE_MANAGER_TYPE" (default "redis")
--redis-database int Target Redis database name
Environment variable: "REDIS_DATABASE" (default -1)
--redis-expiration duration ExpirationFlag for redis Key.
Environment variable: "REDIS_EXPIRATION" (default 2m0s)
--redis-host string Host (address) of Redis server to connect to.
Environment variable: "REDIS_HOST" (default "localhost")
--redis-password string Redis Username password
Environment variable: "REDIS_PASSWORD"
--redis-port string Port (address) of Redis server to connect to.
Environment variable: "REDIS_PORT" (default "6379")
--redis-tls-ca string Trusted Certificate Authority
Environment variable: "REDIS_TLS_CA"
--redis-tls-cert string TLS Certificate to connect to Redis
Environment variable: "REDIS_TLS_CERT"
--redis-tls-enable Enable TLS/SSL to connect to Redis
Environment variable: "REDIS_TLS_ENABLE"
--redis-tls-key string TLS Private Key to connect to Redis
Environment variable: "REDIS_TLS_KEY"
--redis-tls-skip-verify Skip service certificate verification
Environment variable: "REDIS_TLS_SKIP_VERIFY"
--redis-user string Redis Username.
Environment variable: "REDIS_USER"
--topic-tx-recover string Kafka topic for envelopes waiting for their transaction recovered
Environment variable: "TOPIC_TX_RECOVER" (default "topic-tx-recover")
--topic-tx-sender string Kafka topic for envelopes waiting for their transaction sent
Environment variable: "TOPIC_TX_SENDER" (default "topic-tx-sender")
--transaction-scheduler-url string URL of the Transaction Scheduler HTTP endpoint.
Environment variable: "TRANSACTION_SCHEDULER_URL" (default "localhost:8081")
Command line arguments take precedence over environment variables.
Note
For more info on gRPC Context Store target, see gRPC Name Resolution documentation