Documentation ¶
Index ¶
Constants ¶
View Source
const ( RequestTimeout = "REQUESTTIMEOUT" Brokers = "BROKERS" TLSEnabled = "TLS_ENABLED" TLSCa = "TLS_CA" TLSCert = "TLS_CERT" TLSCertKey = "TLS_CERTKEY" TLSInsecure = "TLS_INSECURE" SaslEnabled = "SASL_ENABLED" SaslUsername = "SASL_USERNAME" SaslPassword = "SASL_PASSWORD" SaslMechanism = "SASL_MECHANISM" SaslTokenProviderPlugin = "SASL_TOKENPROVIDER_PLUGIN" SaslTokenProviderOptions = "SASL_TOKENPROVIDER_OPTIONS" ClientID = "CLIENTID" KafkaVersion = "KAFKAVERSION" AvroSchemaRegistry = "AVRO_SCHEMAREGISTRY" AvroJSONCodec = "AVRO_JSONCODEC" ProtobufProtoSetFiles = "PROTOBUF_PROTOSETFILES" ProtobufImportPaths = "PROTOBUF_IMPORTPATHS" ProtobufProtoFiles = "PROTOBUF_PROTOFILES" ProducerPartitioner = "PRODUCER_PARTITIONER" ProducerRequiredAcks = "PRODUCER_REQUIREDACKS" ProducerMaxMessageBytes = "PRODUCER_MAXMESSAGEBYTES" )
View Source
const GoContextKey = "global-config"
Variables ¶
View Source
var EnvVariables = []string{ RequestTimeout, Brokers, TLSEnabled, TLSCa, TLSCert, TLSCertKey, TLSInsecure, SaslEnabled, SaslUsername, SaslPassword, SaslMechanism, SaslTokenProviderPlugin, SaslTokenProviderOptions, ClientID, KafkaVersion, AvroSchemaRegistry, AvroJSONCodec, ProtobufProtoSetFiles, ProtobufImportPaths, ProtobufProtoFiles, ProducerPartitioner, ProducerRequiredAcks, ProducerMaxMessageBytes, }
Functions ¶
func GetCurrentContext ¶
func GetCurrentContext() string
func SetCurrentContext ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.