Documentation ¶
Index ¶
Constants ¶
View Source
const ( // MillisPerDay Is A Duration Convenience MillisPerDay = 24 * 60 * 60 * 1000 // 86400000 // TopicDetailConfigRetentionMs Is The ConfigEntry In The Sarama TopicDetail For Retention Time TopicDetailConfigRetentionMs = "retention.ms" // EventHub Error Codes EventHubErrorCodeUnknown = -2 EventHubErrorCodeParseFailure = -1 EventHubErrorCodeCapacityLimit = 403 EventHubErrorCodeConflict = 409 // KafkaChannelServiceNameSuffix Is The Specific Service Name Suffix For Use With Knative E2E Tests KafkaChannelServiceNameSuffix = "kn-channel" )
Constants
Variables ¶
View Source
var ( // // ConfigKafkaVersionDefault Is The Default Kafka Version // // This is the default value which will be used when creating Sarama.Config if not // otherwise specified in the ConfigMap. It is set to the lowest common denominator // version to provide the most compatible and likely to succeed solution. Specifically, // Sarama's ConsumerGroups repeatedly close due to EOF failures when working against // Azure EventHubs if this is set any higher than V1_0_0_0. // ConfigKafkaVersionDefault = sarama.V1_0_0_0 )
Non-Constant Constants ;)
Functions ¶
This section is empty.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.