heliossarama

package module
v1.37.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 6, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const APIKeySASLAuth = originalSarama.APIKeySASLAuth
View Source 
const AclOperationAll = originalSarama.AclOperationAll
View Source 
const AclOperationAlter = originalSarama.AclOperationAlter
View Source 
const AclOperationAlterConfigs = originalSarama.AclOperationAlterConfigs
View Source 
const AclOperationAny = originalSarama.AclOperationAny
View Source 
const AclOperationClusterAction = originalSarama.AclOperationClusterAction
View Source 
const AclOperationCreate = originalSarama.AclOperationCreate
View Source 
const AclOperationDelete = originalSarama.AclOperationDelete
View Source 
const AclOperationDescribe = originalSarama.AclOperationDescribe
View Source 
const AclOperationDescribeConfigs = originalSarama.AclOperationDescribeConfigs
View Source 
const AclOperationIdempotentWrite = originalSarama.AclOperationIdempotentWrite
View Source 
const AclOperationRead = originalSarama.AclOperationRead
View Source 
const AclOperationUnknown = originalSarama.AclOperationUnknown
View Source 
const AclOperationWrite = originalSarama.AclOperationWrite
View Source 
const AclPatternAny = originalSarama.AclPatternAny
View Source 
const AclPatternLiteral = originalSarama.AclPatternLiteral
View Source 
const AclPatternMatch = originalSarama.AclPatternMatch
View Source 
const AclPatternPrefixed = originalSarama.AclPatternPrefixed
View Source 
const AclPatternUnknown = originalSarama.AclPatternUnknown
View Source 
const AclPermissionAllow = originalSarama.AclPermissionAllow
View Source 
const AclPermissionAny = originalSarama.AclPermissionAny
View Source 
const AclPermissionDeny = originalSarama.AclPermissionDeny
View Source 
const AclPermissionUnknown = originalSarama.AclPermissionUnknown
View Source 
const AclResourceAny = originalSarama.AclResourceAny
View Source 
const AclResourceCluster = originalSarama.AclResourceCluster
View Source 
const AclResourceDelegationToken = originalSarama.AclResourceDelegationToken
View Source 
const AclResourceGroup = originalSarama.AclResourceGroup
View Source 
const AclResourceTopic = originalSarama.AclResourceTopic
View Source 
const AclResourceTransactionalID = originalSarama.AclResourceTransactionalID
View Source 
const AclResourceUnknown = originalSarama.AclResourceUnknown
View Source 
const BrokerLoggerResource = originalSarama.BrokerLoggerResource
View Source 
const BrokerResource = originalSarama.BrokerResource
View Source 
const CompressionGZIP = originalSarama.CompressionGZIP
View Source 
const CompressionLZ4 = originalSarama.CompressionLZ4
View Source 
const CompressionLevelDefault = originalSarama.CompressionLevelDefault
View Source 
const CompressionNone = originalSarama.CompressionNone
View Source 
const CompressionSnappy = originalSarama.CompressionSnappy
View Source 
const CompressionZSTD = originalSarama.CompressionZSTD
View Source 
const ControlRecordAbort = originalSarama.ControlRecordAbort
View Source 
const ControlRecordCommit = originalSarama.ControlRecordCommit
View Source 
const ControlRecordUnknown = originalSarama.ControlRecordUnknown
View Source 
const CoordinatorGroup = originalSarama.CoordinatorGroup
View Source 
const CoordinatorTransaction = originalSarama.CoordinatorTransaction
View Source 
const ErrBrokerNotAvailable = originalSarama.ErrBrokerNotAvailable
View Source 
const ErrClusterAuthorizationFailed = originalSarama.ErrClusterAuthorizationFailed
View Source 
const ErrConcurrentTransactions = originalSarama.ErrConcurrentTransactions
View Source 
const ErrConsumerCoordinatorNotAvailable = originalSarama.ErrConsumerCoordinatorNotAvailable
View Source 
const ErrDelegationTokenAuthDisabled = originalSarama.ErrDelegationTokenAuthDisabled
View Source 
const ErrDelegationTokenAuthorizationFailed = originalSarama.ErrDelegationTokenAuthorizationFailed
View Source 
const ErrDelegationTokenExpired = originalSarama.ErrDelegationTokenExpired
View Source 
const ErrDelegationTokenNotFound = originalSarama.ErrDelegationTokenNotFound
View Source 
const ErrDelegationTokenOwnerMismatch = originalSarama.ErrDelegationTokenOwnerMismatch
View Source 
const ErrDelegationTokenRequestNotAllowed = originalSarama.ErrDelegationTokenRequestNotAllowed
View Source 
const ErrDuplicateSequenceNumber = originalSarama.ErrDuplicateSequenceNumber
View Source 
const ErrElectionNotNeeded = originalSarama.ErrElectionNotNeeded
View Source 
const ErrEligibleLeadersNotAvailable = originalSarama.ErrEligibleLeadersNotAvailable
View Source 
const ErrFencedInstancedId = originalSarama.ErrFencedInstancedId
View Source 
const ErrFencedLeaderEpoch = originalSarama.ErrFencedLeaderEpoch
View Source 
const ErrFetchSessionIDNotFound = originalSarama.ErrFetchSessionIDNotFound
View Source 
const ErrGroupAuthorizationFailed = originalSarama.ErrGroupAuthorizationFailed
View Source 
const ErrGroupIDNotFound = originalSarama.ErrGroupIDNotFound
View Source 
const ErrGroupMaxSizeReached = originalSarama.ErrGroupMaxSizeReached
View Source 
const ErrGroupSubscribedToTopic = originalSarama.ErrGroupSubscribedToTopic
View Source 
const ErrIllegalGeneration = originalSarama.ErrIllegalGeneration
View Source 
const ErrIllegalSASLState = originalSarama.ErrIllegalSASLState
View Source 
const ErrInconsistentGroupProtocol = originalSarama.ErrInconsistentGroupProtocol
View Source 
const ErrInvalidCommitOffsetSize = originalSarama.ErrInvalidCommitOffsetSize
View Source 
const ErrInvalidConfig = originalSarama.ErrInvalidConfig
View Source 
const ErrInvalidFetchSessionEpoch = originalSarama.ErrInvalidFetchSessionEpoch
View Source 
const ErrInvalidGroupId = originalSarama.ErrInvalidGroupId
View Source 
const ErrInvalidMessage = originalSarama.ErrInvalidMessage
View Source 
const ErrInvalidMessageSize = originalSarama.ErrInvalidMessageSize
View Source 
const ErrInvalidPartitions = originalSarama.ErrInvalidPartitions
View Source 
const ErrInvalidPrincipalType = originalSarama.ErrInvalidPrincipalType
View Source 
const ErrInvalidProducerEpoch = originalSarama.ErrInvalidProducerEpoch
View Source 
const ErrInvalidProducerIDMapping = originalSarama.ErrInvalidProducerIDMapping
View Source 
const ErrInvalidRecord = originalSarama.ErrInvalidRecord
View Source 
const ErrInvalidReplicaAssignment = originalSarama.ErrInvalidReplicaAssignment
View Source 
const ErrInvalidReplicationFactor = originalSarama.ErrInvalidReplicationFactor
View Source 
const ErrInvalidRequest = originalSarama.ErrInvalidRequest
View Source 
const ErrInvalidRequiredAcks = originalSarama.ErrInvalidRequiredAcks
View Source 
const ErrInvalidSessionTimeout = originalSarama.ErrInvalidSessionTimeout
View Source 
const ErrInvalidTimestamp = originalSarama.ErrInvalidTimestamp
View Source 
const ErrInvalidTopic = originalSarama.ErrInvalidTopic
View Source 
const ErrInvalidTransactionTimeout = originalSarama.ErrInvalidTransactionTimeout
View Source 
const ErrInvalidTxnState = originalSarama.ErrInvalidTxnState
View Source 
const ErrKafkaStorageError = originalSarama.ErrKafkaStorageError
View Source 
const ErrLeaderNotAvailable = originalSarama.ErrLeaderNotAvailable
View Source 
const ErrListenerNotFound = originalSarama.ErrListenerNotFound
View Source 
const ErrLogDirNotFound = originalSarama.ErrLogDirNotFound
View Source 
const ErrMemberIdRequired = originalSarama.ErrMemberIdRequired
View Source 
const ErrMessageSetSizeTooLarge = originalSarama.ErrMessageSetSizeTooLarge
View Source 
const ErrMessageSizeTooLarge = originalSarama.ErrMessageSizeTooLarge
View Source 
const ErrNetworkException = originalSarama.ErrNetworkException
View Source 
const ErrNoError = originalSarama.ErrNoError
View Source 
const ErrNoReassignmentInProgress = originalSarama.ErrNoReassignmentInProgress
View Source 
const ErrNonEmptyGroup = originalSarama.ErrNonEmptyGroup
View Source 
const ErrNotController = originalSarama.ErrNotController
View Source 
const ErrNotCoordinatorForConsumer = originalSarama.ErrNotCoordinatorForConsumer
View Source 
const ErrNotEnoughReplicas = originalSarama.ErrNotEnoughReplicas
View Source 
const ErrNotEnoughReplicasAfterAppend = originalSarama.ErrNotEnoughReplicasAfterAppend
View Source 
const ErrNotLeaderForPartition = originalSarama.ErrNotLeaderForPartition
View Source 
const ErrOffsetMetadataTooLarge = originalSarama.ErrOffsetMetadataTooLarge
View Source 
const ErrOffsetNotAvailable = originalSarama.ErrOffsetNotAvailable
View Source 
const ErrOffsetOutOfRange = originalSarama.ErrOffsetOutOfRange
View Source 
const ErrOffsetsLoadInProgress = originalSarama.ErrOffsetsLoadInProgress
View Source 
const ErrOperationNotAttempted = originalSarama.ErrOperationNotAttempted
View Source 
const ErrOutOfOrderSequenceNumber = originalSarama.ErrOutOfOrderSequenceNumber
View Source 
const ErrPolicyViolation = originalSarama.ErrPolicyViolation
View Source 
const ErrPreferredLeaderNotAvailable = originalSarama.ErrPreferredLeaderNotAvailable
View Source 
const ErrProducerFenced = originalSarama.ErrProducerFenced
View Source 
const ErrReassignmentInProgress = originalSarama.ErrReassignmentInProgress
View Source 
const ErrRebalanceInProgress = originalSarama.ErrRebalanceInProgress
View Source 
const ErrReplicaNotAvailable = originalSarama.ErrReplicaNotAvailable
View Source 
const ErrRequestTimedOut = originalSarama.ErrRequestTimedOut
View Source 
const ErrSASLAuthenticationFailed = originalSarama.ErrSASLAuthenticationFailed
View Source 
const ErrSecurityDisabled = originalSarama.ErrSecurityDisabled
View Source 
const ErrStaleBrokerEpoch = originalSarama.ErrStaleBrokerEpoch
View Source 
const ErrStaleControllerEpochCode = originalSarama.ErrStaleControllerEpochCode
View Source 
const ErrThrottlingQuotaExceeded = originalSarama.ErrThrottlingQuotaExceeded
View Source 
const ErrTopicAlreadyExists = originalSarama.ErrTopicAlreadyExists
View Source 
const ErrTopicAuthorizationFailed = originalSarama.ErrTopicAuthorizationFailed
View Source 
const ErrTopicDeletionDisabled = originalSarama.ErrTopicDeletionDisabled
View Source 
const ErrTransactionCoordinatorFenced = originalSarama.ErrTransactionCoordinatorFenced
View Source 
const ErrTransactionalIDAuthorizationFailed = originalSarama.ErrTransactionalIDAuthorizationFailed
View Source 
const ErrUnknown = originalSarama.ErrUnknown
View Source 
const ErrUnknownLeaderEpoch = originalSarama.ErrUnknownLeaderEpoch
View Source 
const ErrUnknownMemberId = originalSarama.ErrUnknownMemberId
View Source 
const ErrUnknownProducerID = originalSarama.ErrUnknownProducerID
View Source 
const ErrUnknownTopicOrPartition = originalSarama.ErrUnknownTopicOrPartition
View Source 
const ErrUnstableOffsetCommit = originalSarama.ErrUnstableOffsetCommit
View Source 
const ErrUnsupportedCompressionType = originalSarama.ErrUnsupportedCompressionType
View Source 
const ErrUnsupportedForMessageFormat = originalSarama.ErrUnsupportedForMessageFormat
View Source 
const ErrUnsupportedSASLMechanism = originalSarama.ErrUnsupportedSASLMechanism
View Source 
const ErrUnsupportedVersion = originalSarama.ErrUnsupportedVersion
View Source 
const GSS_API_FINISH = originalSarama.GSS_API_FINISH
View Source 
const GSS_API_GENERIC_TAG = originalSarama.GSS_API_GENERIC_TAG
View Source 
const GSS_API_INITIAL = originalSarama.GSS_API_INITIAL
View Source 
const GSS_API_VERIFY = originalSarama.GSS_API_VERIFY
View Source 
const GroupGenerationUndefined = originalSarama.GroupGenerationUndefined
View Source 
const IncrementalAlterConfigsOperationAppend = originalSarama.IncrementalAlterConfigsOperationAppend
View Source 
const IncrementalAlterConfigsOperationDelete = originalSarama.IncrementalAlterConfigsOperationDelete
View Source 
const IncrementalAlterConfigsOperationSet = originalSarama.IncrementalAlterConfigsOperationSet
View Source 
const IncrementalAlterConfigsOperationSubtract = originalSarama.IncrementalAlterConfigsOperationSubtract
View Source 
const KRB5_KEYTAB_AUTH = originalSarama.KRB5_KEYTAB_AUTH
View Source 
const KRB5_USER_AUTH = originalSarama.KRB5_USER_AUTH
View Source 
const MAX_GROUP_INSTANCE_ID_LENGTH = originalSarama.MAX_GROUP_INSTANCE_ID_LENGTH
View Source 
const NoResponse = originalSarama.NoResponse
View Source 
const OffsetNewest = originalSarama.OffsetNewest
View Source 
const OffsetOldest = originalSarama.OffsetOldest
View Source 
const ProducerTxnFlagAbortableError = originalSarama.ProducerTxnFlagAbortableError
View Source 
const ProducerTxnFlagAbortingTransaction = originalSarama.ProducerTxnFlagAbortingTransaction
View Source 
const ProducerTxnFlagCommittingTransaction = originalSarama.ProducerTxnFlagCommittingTransaction
View Source 
const ProducerTxnFlagEndTransaction = originalSarama.ProducerTxnFlagEndTransaction
View Source 
const ProducerTxnFlagFatalError = originalSarama.ProducerTxnFlagFatalError
View Source 
const ProducerTxnFlagInError = originalSarama.ProducerTxnFlagInError
View Source 
const ProducerTxnFlagInTransaction = originalSarama.ProducerTxnFlagInTransaction
View Source 
const ProducerTxnFlagInitializing = originalSarama.ProducerTxnFlagInitializing
View Source 
const ProducerTxnFlagReady = originalSarama.ProducerTxnFlagReady
View Source 
const ProducerTxnFlagUninitialized = originalSarama.ProducerTxnFlagUninitialized
View Source 
const QuotaEntityClientID = originalSarama.QuotaEntityClientID
View Source 
const QuotaEntityIP = originalSarama.QuotaEntityIP
View Source 
const QuotaEntityUser = originalSarama.QuotaEntityUser
View Source 
const QuotaMatchAny = originalSarama.QuotaMatchAny
View Source 
const QuotaMatchDefault = originalSarama.QuotaMatchDefault
View Source 
const QuotaMatchExact = originalSarama.QuotaMatchExact
View Source 
const RangeBalanceStrategyName = originalSarama.RangeBalanceStrategyName
View Source 
const ReadCommitted = originalSarama.ReadCommitted
View Source 
const ReadUncommitted = originalSarama.ReadUncommitted
View Source 
const ReceiveTime = originalSarama.ReceiveTime
View Source 
const RoundRobinBalanceStrategyName = originalSarama.RoundRobinBalanceStrategyName
View Source 
const SASLExtKeyAuth = originalSarama.SASLExtKeyAuth
View Source 
const SASLHandshakeV0 = originalSarama.SASLHandshakeV0
View Source 
const SASLHandshakeV1 = originalSarama.SASLHandshakeV1
View Source 
const SASLTypeGSSAPI = originalSarama.SASLTypeGSSAPI
View Source 
const SASLTypeOAuth = originalSarama.SASLTypeOAuth
View Source 
const SASLTypePlaintext = originalSarama.SASLTypePlaintext
View Source 
const SASLTypeSCRAMSHA256 = originalSarama.SASLTypeSCRAMSHA256
View Source 
const SASLTypeSCRAMSHA512 = originalSarama.SASLTypeSCRAMSHA512
View Source 
const SCRAM_MECHANISM_SHA_256 = originalSarama.SCRAM_MECHANISM_SHA_256
View Source 
const SCRAM_MECHANISM_SHA_512 = originalSarama.SCRAM_MECHANISM_SHA_512
View Source 
const SCRAM_MECHANISM_UNKNOWN = originalSarama.SCRAM_MECHANISM_UNKNOWN
View Source 
const SourceDefault = originalSarama.SourceDefault
View Source 
const SourceDynamicBroker = originalSarama.SourceDynamicBroker
View Source 
const SourceDynamicDefaultBroker = originalSarama.SourceDynamicDefaultBroker
View Source 
const SourceStaticBroker = originalSarama.SourceStaticBroker
View Source 
const SourceTopic = originalSarama.SourceTopic
View Source 
const SourceUnknown = originalSarama.SourceUnknown
View Source 
const StickyBalanceStrategyName = originalSarama.StickyBalanceStrategyName
View Source 
const TOK_ID_KRB_AP_REQ = originalSarama.TOK_ID_KRB_AP_REQ
View Source 
const TopicResource = originalSarama.TopicResource
View Source 
const UnknownResource = originalSarama.UnknownResource
View Source 
const WaitForAll = originalSarama.WaitForAll
View Source 
const WaitForLocal = originalSarama.WaitForLocal

Variables

View Source 
var BalanceStrategyRange = originalSarama.BalanceStrategyRange
View Source 
var BalanceStrategyRoundRobin = originalSarama.BalanceStrategyRoundRobin
View Source 
var BalanceStrategySticky = originalSarama.BalanceStrategySticky
View Source 
var DebugLogger = originalSarama.DebugLogger
View Source 
var DefaultVersion = originalSarama.DefaultVersion
View Source 
var ErrAddPartitionsToTxn = originalSarama.ErrAddPartitionsToTxn
View Source 
var ErrAlreadyConnected = originalSarama.ErrAlreadyConnected
View Source 
var ErrBrokerNotFound = originalSarama.ErrBrokerNotFound
View Source 
var ErrCannotTransitionNilError = originalSarama.ErrCannotTransitionNilError
View Source 
var ErrClosedClient = originalSarama.ErrClosedClient
View Source 
var ErrClosedConsumerGroup = originalSarama.ErrClosedConsumerGroup
View Source 
var ErrConsumerOffsetNotAdvanced = originalSarama.ErrConsumerOffsetNotAdvanced
View Source 
var ErrControllerNotAvailable = originalSarama.ErrControllerNotAvailable
View Source 
var ErrCreateACLs = originalSarama.ErrCreateACLs
View Source 
var ErrDeleteRecords = originalSarama.ErrDeleteRecords
View Source 
var ErrIncompleteResponse = originalSarama.ErrIncompleteResponse
View Source 
var ErrInsufficientData = originalSarama.ErrInsufficientData
View Source 
var ErrInvalidPartition = originalSarama.ErrInvalidPartition
View Source 
var ErrMessageTooLarge = originalSarama.ErrMessageTooLarge
View Source 
var ErrNoTopicsToUpdateMetadata = originalSarama.ErrNoTopicsToUpdateMetadata
View Source 
var ErrNonTransactedProducer = originalSarama.ErrNonTransactedProducer
View Source 
var ErrNotConnected = originalSarama.ErrNotConnected
View Source 
var ErrOutOfBrokers = originalSarama.ErrOutOfBrokers
View Source 
var ErrReassignPartitions = originalSarama.ErrReassignPartitions
View Source 
var ErrShuttingDown = originalSarama.ErrShuttingDown
View Source 
var ErrTransactionNotReady = originalSarama.ErrTransactionNotReady
View Source 
var ErrTransitionNotAllowed = originalSarama.ErrTransitionNotAllowed
View Source 
var ErrTxnOffsetCommit = originalSarama.ErrTxnOffsetCommit
View Source 
var ErrTxnUnableToParseResponse = originalSarama.ErrTxnUnableToParseResponse
View Source 
var ErrUnknownScramMechanism = originalSarama.ErrUnknownScramMechanism
View Source 
var GROUP_INSTANCE_ID_REGEXP = originalSarama.GROUP_INSTANCE_ID_REGEXP
View Source 
var Logger = originalSarama.Logger
View Source 
var MaxRequestSize = originalSarama.MaxRequestSize
View Source 
var MaxResponseSize = originalSarama.MaxResponseSize
View Source 
var MaxVersion = originalSarama.MaxVersion
View Source 
var MinVersion = originalSarama.MinVersion
View Source 
var MultiErrorFormat = originalSarama.MultiErrorFormat
View Source 
var NoNode = originalSarama.NoNode
View Source 
var PanicHandler = originalSarama.PanicHandler
View Source 
var SupportedVersions = originalSarama.SupportedVersions
View Source 
var V0_10_0_0 = originalSarama.V0_10_0_0
View Source 
var V0_10_0_1 = originalSarama.V0_10_0_1
View Source 
var V0_10_1_0 = originalSarama.V0_10_1_0
View Source 
var V0_10_1_1 = originalSarama.V0_10_1_1
View Source 
var V0_10_2_0 = originalSarama.V0_10_2_0
View Source 
var V0_10_2_1 = originalSarama.V0_10_2_1
View Source 
var V0_10_2_2 = originalSarama.V0_10_2_2
View Source 
var V0_11_0_0 = originalSarama.V0_11_0_0
View Source 
var V0_11_0_1 = originalSarama.V0_11_0_1
View Source 
var V0_11_0_2 = originalSarama.V0_11_0_2
View Source 
var V0_8_2_0 = originalSarama.V0_8_2_0
View Source 
var V0_8_2_1 = originalSarama.V0_8_2_1
View Source 
var V0_8_2_2 = originalSarama.V0_8_2_2
View Source 
var V0_9_0_0 = originalSarama.V0_9_0_0
View Source 
var V0_9_0_1 = originalSarama.V0_9_0_1
View Source 
var V1_0_0_0 = originalSarama.V1_0_0_0
View Source 
var V1_0_1_0 = originalSarama.V1_0_1_0
View Source 
var V1_0_2_0 = originalSarama.V1_0_2_0
View Source 
var V1_1_0_0 = originalSarama.V1_1_0_0
View Source 
var V1_1_1_0 = originalSarama.V1_1_1_0
View Source 
var V2_0_0_0 = originalSarama.V2_0_0_0
View Source 
var V2_0_1_0 = originalSarama.V2_0_1_0
View Source 
var V2_1_0_0 = originalSarama.V2_1_0_0
View Source 
var V2_1_1_0 = originalSarama.V2_1_1_0
View Source 
var V2_2_0_0 = originalSarama.V2_2_0_0
View Source 
var V2_2_1_0 = originalSarama.V2_2_1_0
View Source 
var V2_2_2_0 = originalSarama.V2_2_2_0
View Source 
var V2_3_0_0 = originalSarama.V2_3_0_0
View Source 
var V2_3_1_0 = originalSarama.V2_3_1_0
View Source 
var V2_4_0_0 = originalSarama.V2_4_0_0
View Source 
var V2_4_1_0 = originalSarama.V2_4_1_0
View Source 
var V2_5_0_0 = originalSarama.V2_5_0_0
View Source 
var V2_5_1_0 = originalSarama.V2_5_1_0
View Source 
var V2_6_0_0 = originalSarama.V2_6_0_0
View Source 
var V2_6_1_0 = originalSarama.V2_6_1_0
View Source 
var V2_6_2_0 = originalSarama.V2_6_2_0
View Source 
var V2_6_3_0 = originalSarama.V2_6_3_0
View Source 
var V2_7_0_0 = originalSarama.V2_7_0_0
View Source 
var V2_7_1_0 = originalSarama.V2_7_1_0
View Source 
var V2_7_2_0 = originalSarama.V2_7_2_0
View Source 
var V2_8_0_0 = originalSarama.V2_8_0_0
View Source 
var V2_8_1_0 = originalSarama.V2_8_1_0
View Source 
var V2_8_2_0 = originalSarama.V2_8_2_0
View Source 
var V3_0_0_0 = originalSarama.V3_0_0_0
View Source 
var V3_0_1_0 = originalSarama.V3_0_1_0
View Source 
var V3_0_2_0 = originalSarama.V3_0_2_0
View Source 
var V3_1_0_0 = originalSarama.V3_1_0_0
View Source 
var V3_1_1_0 = originalSarama.V3_1_1_0
View Source 
var V3_1_2_0 = originalSarama.V3_1_2_0
View Source 
var V3_2_0_0 = originalSarama.V3_2_0_0
View Source 
var V3_2_1_0 = originalSarama.V3_2_1_0
View Source 
var V3_2_2_0 = originalSarama.V3_2_2_0
View Source 
var V3_2_3_0 = originalSarama.V3_2_3_0

Functions

func InjectContextToMessage 

func InjectContextToMessage(ctx context.Context, message *originalSarama.ProducerMessage)

func Wrap 

func Wrap(sentinel error, wrapped ...error) interface{}

The original return type of "Wrap" is "sentinelError", but the proxy cannot access it, so it returns an interface.

Types

type AbortedTransaction 

type AbortedTransaction = originalSarama.AbortedTransaction

type AccessToken 

type AccessToken = originalSarama.AccessToken

type AccessTokenProvider 

type AccessTokenProvider = originalSarama.AccessTokenProvider

type Acl 

type Acl = originalSarama.Acl

type AclCreation 

type AclCreation = originalSarama.AclCreation

type AclCreationResponse 

type AclCreationResponse = originalSarama.AclCreationResponse

type AclFilter 

type AclFilter = originalSarama.AclFilter

type AclOperation 

type AclOperation = originalSarama.AclOperation

type AclPermissionType 

type AclPermissionType = originalSarama.AclPermissionType

type AclResourcePatternType 

type AclResourcePatternType = originalSarama.AclResourcePatternType

type AclResourceType 

type AclResourceType = originalSarama.AclResourceType

type AddOffsetsToTxnRequest 

type AddOffsetsToTxnRequest = originalSarama.AddOffsetsToTxnRequest

type AddOffsetsToTxnResponse 

type AddOffsetsToTxnResponse = originalSarama.AddOffsetsToTxnResponse

type AddPartitionsToTxnRequest 

type AddPartitionsToTxnRequest = originalSarama.AddPartitionsToTxnRequest

type AddPartitionsToTxnResponse 

type AddPartitionsToTxnResponse = originalSarama.AddPartitionsToTxnResponse

type AlterClientQuotasEntry 

type AlterClientQuotasEntry = originalSarama.AlterClientQuotasEntry

type AlterClientQuotasEntryResponse 

type AlterClientQuotasEntryResponse = originalSarama.AlterClientQuotasEntryResponse

type AlterClientQuotasRequest 

type AlterClientQuotasRequest = originalSarama.AlterClientQuotasRequest

type AlterClientQuotasResponse 

type AlterClientQuotasResponse = originalSarama.AlterClientQuotasResponse

type AlterConfigsRequest 

type AlterConfigsRequest = originalSarama.AlterConfigsRequest

type AlterConfigsResource 

type AlterConfigsResource = originalSarama.AlterConfigsResource

type AlterConfigsResourceResponse 

type AlterConfigsResourceResponse = originalSarama.AlterConfigsResourceResponse

type AlterConfigsResponse 

type AlterConfigsResponse = originalSarama.AlterConfigsResponse

type AlterPartitionReassignmentsRequest 

type AlterPartitionReassignmentsRequest = originalSarama.AlterPartitionReassignmentsRequest

type AlterPartitionReassignmentsResponse 

type AlterPartitionReassignmentsResponse = originalSarama.AlterPartitionReassignmentsResponse

type AlterUserScramCredentialsDelete 

type AlterUserScramCredentialsDelete = originalSarama.AlterUserScramCredentialsDelete

type AlterUserScramCredentialsRequest 

type AlterUserScramCredentialsRequest = originalSarama.AlterUserScramCredentialsRequest

type AlterUserScramCredentialsResponse 

type AlterUserScramCredentialsResponse = originalSarama.AlterUserScramCredentialsResponse

type AlterUserScramCredentialsResult 

type AlterUserScramCredentialsResult = originalSarama.AlterUserScramCredentialsResult

type AlterUserScramCredentialsUpsert 

type AlterUserScramCredentialsUpsert = originalSarama.AlterUserScramCredentialsUpsert

type ApiVersionsRequest 

type ApiVersionsRequest = originalSarama.ApiVersionsRequest

type ApiVersionsResponse 

type ApiVersionsResponse = originalSarama.ApiVersionsResponse

type ApiVersionsResponseKey 

type ApiVersionsResponseKey = originalSarama.ApiVersionsResponseKey

type AsyncProducer 

type AsyncProducer = originalSarama.AsyncProducer

func NewAsyncProducer 

func NewAsyncProducer(addrs []string, conf *Config) (AsyncProducer, error)

func NewAsyncProducerFromClient 

func NewAsyncProducerFromClient(client Client) (AsyncProducer, error)

type BalanceStrategy 

type BalanceStrategy = originalSarama.BalanceStrategy

type BalanceStrategyPlan 

type BalanceStrategyPlan = originalSarama.BalanceStrategyPlan

type Broker 

type Broker = originalSarama.Broker

func NewBroker 

func NewBroker(addr string) *Broker

type ByteEncoder 

type ByteEncoder = originalSarama.ByteEncoder

type Client 

type Client = originalSarama.Client

func NewClient 

func NewClient(addrs []string, conf *Config) (Client, error)

type ClientQuotasOp 

type ClientQuotasOp = originalSarama.ClientQuotasOp

type ClusterAdmin 

type ClusterAdmin = originalSarama.ClusterAdmin

func NewClusterAdmin 

func NewClusterAdmin(addrs []string, conf *Config) (ClusterAdmin, error)

func NewClusterAdminFromClient 

func NewClusterAdminFromClient(client Client) (ClusterAdmin, error)

type CompressionCodec 

type CompressionCodec = originalSarama.CompressionCodec

type Config 

type Config = originalSarama.Config

func NewConfig 

func NewConfig() *Config

type ConfigEntry 

type ConfigEntry = originalSarama.ConfigEntry

type ConfigResource 

type ConfigResource = originalSarama.ConfigResource

type ConfigResourceType 

type ConfigResourceType = originalSarama.ConfigResourceType

type ConfigSource 

type ConfigSource = originalSarama.ConfigSource

type ConfigSynonym 

type ConfigSynonym = originalSarama.ConfigSynonym

type ConfigurationError 

type ConfigurationError = originalSarama.ConfigurationError

type Consumer 

type Consumer = originalSarama.Consumer

func NewConsumer 

func NewConsumer(addrs []string, config *Config) (Consumer, error)

func NewConsumerFromClient 

func NewConsumerFromClient(client Client) (Consumer, error)

type ConsumerError 

type ConsumerError = originalSarama.ConsumerError

type ConsumerErrors 

type ConsumerErrors = originalSarama.ConsumerErrors

type ConsumerGroup 

type ConsumerGroup = originalSarama.ConsumerGroup

func NewConsumerGroup 

func NewConsumerGroup(addrs []string, groupID string, config *Config) (ConsumerGroup, error)

func NewConsumerGroupFromClient 

func NewConsumerGroupFromClient(groupID string, client Client) (ConsumerGroup, error)

type ConsumerGroupClaim 

type ConsumerGroupClaim = originalSarama.ConsumerGroupClaim

type ConsumerGroupHandler 

type ConsumerGroupHandler = originalSarama.ConsumerGroupHandler

type ConsumerGroupMemberAssignment 

type ConsumerGroupMemberAssignment = originalSarama.ConsumerGroupMemberAssignment

type ConsumerGroupMemberMetadata 

type ConsumerGroupMemberMetadata = originalSarama.ConsumerGroupMemberMetadata

type ConsumerGroupSession 

type ConsumerGroupSession = originalSarama.ConsumerGroupSession

type ConsumerInterceptor 

type ConsumerInterceptor = originalSarama.ConsumerInterceptor

type ConsumerMessage 

type ConsumerMessage = originalSarama.ConsumerMessage

type ConsumerMetadataRequest 

type ConsumerMetadataRequest = originalSarama.ConsumerMetadataRequest

type ConsumerMetadataResponse 

type ConsumerMetadataResponse = originalSarama.ConsumerMetadataResponse

type ControlRecord 

type ControlRecord = originalSarama.ControlRecord

type ControlRecordType 

type ControlRecordType = originalSarama.ControlRecordType

type CoordinatorType 

type CoordinatorType = originalSarama.CoordinatorType

type CreateAclsRequest 

type CreateAclsRequest = originalSarama.CreateAclsRequest

type CreateAclsResponse 

type CreateAclsResponse = originalSarama.CreateAclsResponse

type CreatePartitionsRequest 

type CreatePartitionsRequest = originalSarama.CreatePartitionsRequest

type CreatePartitionsResponse 

type CreatePartitionsResponse = originalSarama.CreatePartitionsResponse

type CreateTopicsRequest 

type CreateTopicsRequest = originalSarama.CreateTopicsRequest

type CreateTopicsResponse 

type CreateTopicsResponse = originalSarama.CreateTopicsResponse

type DeleteAclsRequest 

type DeleteAclsRequest = originalSarama.DeleteAclsRequest

type DeleteAclsResponse 

type DeleteAclsResponse = originalSarama.DeleteAclsResponse

type DeleteGroupsRequest 

type DeleteGroupsRequest = originalSarama.DeleteGroupsRequest

type DeleteGroupsResponse 

type DeleteGroupsResponse = originalSarama.DeleteGroupsResponse

type DeleteOffsetsRequest 

type DeleteOffsetsRequest = originalSarama.DeleteOffsetsRequest

type DeleteOffsetsResponse 

type DeleteOffsetsResponse = originalSarama.DeleteOffsetsResponse

type DeleteRecordsRequest 

type DeleteRecordsRequest = originalSarama.DeleteRecordsRequest

type DeleteRecordsRequestTopic 

type DeleteRecordsRequestTopic = originalSarama.DeleteRecordsRequestTopic

type DeleteRecordsResponse 

type DeleteRecordsResponse = originalSarama.DeleteRecordsResponse

type DeleteRecordsResponsePartition 

type DeleteRecordsResponsePartition = originalSarama.DeleteRecordsResponsePartition

type DeleteRecordsResponseTopic 

type DeleteRecordsResponseTopic = originalSarama.DeleteRecordsResponseTopic

type DeleteTopicsRequest 

type DeleteTopicsRequest = originalSarama.DeleteTopicsRequest

type DeleteTopicsResponse 

type DeleteTopicsResponse = originalSarama.DeleteTopicsResponse

type DescribeAclsRequest 

type DescribeAclsRequest = originalSarama.DescribeAclsRequest

type DescribeAclsResponse 

type DescribeAclsResponse = originalSarama.DescribeAclsResponse

type DescribeClientQuotasEntry 

type DescribeClientQuotasEntry = originalSarama.DescribeClientQuotasEntry

type DescribeClientQuotasRequest 

type DescribeClientQuotasRequest = originalSarama.DescribeClientQuotasRequest

type DescribeClientQuotasResponse 

type DescribeClientQuotasResponse = originalSarama.DescribeClientQuotasResponse

type DescribeConfigsRequest 

type DescribeConfigsRequest = originalSarama.DescribeConfigsRequest

type DescribeConfigsResponse 

type DescribeConfigsResponse = originalSarama.DescribeConfigsResponse

type DescribeGroupsRequest 

type DescribeGroupsRequest = originalSarama.DescribeGroupsRequest

type DescribeGroupsResponse 

type DescribeGroupsResponse = originalSarama.DescribeGroupsResponse

type DescribeLogDirsRequest 

type DescribeLogDirsRequest = originalSarama.DescribeLogDirsRequest

type DescribeLogDirsRequestTopic 

type DescribeLogDirsRequestTopic = originalSarama.DescribeLogDirsRequestTopic

type DescribeLogDirsResponse 

type DescribeLogDirsResponse = originalSarama.DescribeLogDirsResponse

type DescribeLogDirsResponseDirMetadata 

type DescribeLogDirsResponseDirMetadata = originalSarama.DescribeLogDirsResponseDirMetadata

type DescribeLogDirsResponsePartition 

type DescribeLogDirsResponsePartition = originalSarama.DescribeLogDirsResponsePartition

type DescribeLogDirsResponseTopic 

type DescribeLogDirsResponseTopic = originalSarama.DescribeLogDirsResponseTopic

type DescribeUserScramCredentialsRequest 

type DescribeUserScramCredentialsRequest = originalSarama.DescribeUserScramCredentialsRequest

type DescribeUserScramCredentialsRequestUser 

type DescribeUserScramCredentialsRequestUser = originalSarama.DescribeUserScramCredentialsRequestUser

type DescribeUserScramCredentialsResponse 

type DescribeUserScramCredentialsResponse = originalSarama.DescribeUserScramCredentialsResponse

type DescribeUserScramCredentialsResult 

type DescribeUserScramCredentialsResult = originalSarama.DescribeUserScramCredentialsResult

type DynamicConsistencyPartitioner 

type DynamicConsistencyPartitioner = originalSarama.DynamicConsistencyPartitioner

type Encoder 

type Encoder = originalSarama.Encoder

type EndTxnRequest 

type EndTxnRequest = originalSarama.EndTxnRequest

type EndTxnResponse 

type EndTxnResponse = originalSarama.EndTxnResponse

type FetchRequest 

type FetchRequest = originalSarama.FetchRequest

type FetchResponse 

type FetchResponse = originalSarama.FetchResponse

type FetchResponseBlock 

type FetchResponseBlock = originalSarama.FetchResponseBlock

type FilterResponse 

type FilterResponse = originalSarama.FilterResponse

type FindCoordinatorRequest 

type FindCoordinatorRequest = originalSarama.FindCoordinatorRequest

type FindCoordinatorResponse 

type FindCoordinatorResponse = originalSarama.FindCoordinatorResponse

type GSSAPIConfig 

type GSSAPIConfig = originalSarama.GSSAPIConfig

type GSSAPIKerberosAuth 

type GSSAPIKerberosAuth = originalSarama.GSSAPIKerberosAuth

type GSSApiHandlerFunc 

type GSSApiHandlerFunc = originalSarama.GSSApiHandlerFunc

type GroupDescription 

type GroupDescription = originalSarama.GroupDescription

type GroupMember 

type GroupMember = originalSarama.GroupMember

type GroupMemberDescription 

type GroupMemberDescription = originalSarama.GroupMemberDescription

type GroupProtocol 

type GroupProtocol = originalSarama.GroupProtocol

type HashPartitionerOption 

type HashPartitionerOption = originalSarama.HashPartitionerOption

func WithAbsFirst 

func WithAbsFirst() HashPartitionerOption

func WithCustomFallbackPartitioner 

func WithCustomFallbackPartitioner(randomHP Partitioner) HashPartitionerOption

func WithCustomHashFunction 

func WithCustomHashFunction(hasher func() hash.Hash32) HashPartitionerOption

type HeartbeatRequest 

type HeartbeatRequest = originalSarama.HeartbeatRequest

type HeartbeatResponse 

type HeartbeatResponse = originalSarama.HeartbeatResponse

type IncrementalAlterConfigsEntry 

type IncrementalAlterConfigsEntry = originalSarama.IncrementalAlterConfigsEntry

type IncrementalAlterConfigsOperation 

type IncrementalAlterConfigsOperation = originalSarama.IncrementalAlterConfigsOperation

type IncrementalAlterConfigsRequest 

type IncrementalAlterConfigsRequest = originalSarama.IncrementalAlterConfigsRequest

type IncrementalAlterConfigsResource 

type IncrementalAlterConfigsResource = originalSarama.IncrementalAlterConfigsResource

type IncrementalAlterConfigsResponse 

type IncrementalAlterConfigsResponse = originalSarama.IncrementalAlterConfigsResponse

type InitProducerIDRequest 

type InitProducerIDRequest = originalSarama.InitProducerIDRequest

type InitProducerIDResponse 

type InitProducerIDResponse = originalSarama.InitProducerIDResponse

type IsolationLevel 

type IsolationLevel = originalSarama.IsolationLevel

type JoinGroupRequest 

type JoinGroupRequest = originalSarama.JoinGroupRequest

type JoinGroupResponse 

type JoinGroupResponse = originalSarama.JoinGroupResponse

type KError 

type KError = originalSarama.KError

type KafkaGSSAPIHandler 

type KafkaGSSAPIHandler = originalSarama.KafkaGSSAPIHandler

type KafkaVersion 

type KafkaVersion = originalSarama.KafkaVersion

func ParseKafkaVersion 

func ParseKafkaVersion(s string) (KafkaVersion, error)

type KerberosClient 

type KerberosClient = originalSarama.KerberosClient

func NewKerberosClient 

func NewKerberosClient(config *GSSAPIConfig) (KerberosClient, error)

type KerberosGoKrb5Client 

type KerberosGoKrb5Client = originalSarama.KerberosGoKrb5Client

type LeaveGroupRequest 

type LeaveGroupRequest = originalSarama.LeaveGroupRequest

type LeaveGroupResponse 

type LeaveGroupResponse = originalSarama.LeaveGroupResponse

type ListGroupsRequest 

type ListGroupsRequest = originalSarama.ListGroupsRequest

type ListGroupsResponse 

type ListGroupsResponse = originalSarama.ListGroupsResponse

type ListPartitionReassignmentsRequest 

type ListPartitionReassignmentsRequest = originalSarama.ListPartitionReassignmentsRequest

type ListPartitionReassignmentsResponse 

type ListPartitionReassignmentsResponse = originalSarama.ListPartitionReassignmentsResponse

type MatchingAcl 

type MatchingAcl = originalSarama.MatchingAcl

type MemberIdentity 

type MemberIdentity = originalSarama.MemberIdentity

type MemberResponse 

type MemberResponse = originalSarama.MemberResponse

type Message 

type Message = originalSarama.Message

type MessageBlock 

type MessageBlock = originalSarama.MessageBlock

type MessageSet 

type MessageSet = originalSarama.MessageSet

type MetadataRequest 

type MetadataRequest = originalSarama.MetadataRequest

type MetadataResponse 

type MetadataResponse = originalSarama.MetadataResponse

type MockAlterConfigsResponse 

type MockAlterConfigsResponse = originalSarama.MockAlterConfigsResponse

func NewMockAlterConfigsResponse 

func NewMockAlterConfigsResponse(t TestReporter) *MockAlterConfigsResponse

type MockAlterConfigsResponseWithErrorCode 

type MockAlterConfigsResponseWithErrorCode = originalSarama.MockAlterConfigsResponseWithErrorCode

func NewMockAlterConfigsResponseWithErrorCode 

func NewMockAlterConfigsResponseWithErrorCode(t TestReporter) *MockAlterConfigsResponseWithErrorCode

type MockAlterPartitionReassignmentsResponse 

type MockAlterPartitionReassignmentsResponse = originalSarama.MockAlterPartitionReassignmentsResponse

func NewMockAlterPartitionReassignmentsResponse 

func NewMockAlterPartitionReassignmentsResponse(t TestReporter) *MockAlterPartitionReassignmentsResponse

type MockApiVersionsResponse 

type MockApiVersionsResponse = originalSarama.MockApiVersionsResponse

func NewMockApiVersionsResponse 

func NewMockApiVersionsResponse(t TestReporter) *MockApiVersionsResponse

type MockBroker 

type MockBroker = originalSarama.MockBroker

func NewMockBroker 

func NewMockBroker(t TestReporter, brokerID int32) *MockBroker

func NewMockBrokerAddr 

func NewMockBrokerAddr(t TestReporter, brokerID int32, addr string) *MockBroker

func NewMockBrokerListener 

func NewMockBrokerListener(t TestReporter, brokerID int32, listener net.Listener) *MockBroker

type MockConsumerMetadataResponse 

type MockConsumerMetadataResponse = originalSarama.MockConsumerMetadataResponse

func NewMockConsumerMetadataResponse 

func NewMockConsumerMetadataResponse(t TestReporter) *MockConsumerMetadataResponse

type MockCreateAclsResponse 

type MockCreateAclsResponse = originalSarama.MockCreateAclsResponse

func NewMockCreateAclsResponse 

func NewMockCreateAclsResponse(t TestReporter) *MockCreateAclsResponse

type MockCreateAclsResponseError 

type MockCreateAclsResponseError = originalSarama.MockCreateAclsResponseError

func NewMockCreateAclsResponseWithError 

func NewMockCreateAclsResponseWithError(t TestReporter) *MockCreateAclsResponseError

type MockCreatePartitionsResponse 

type MockCreatePartitionsResponse = originalSarama.MockCreatePartitionsResponse

func NewMockCreatePartitionsResponse 

func NewMockCreatePartitionsResponse(t TestReporter) *MockCreatePartitionsResponse

type MockCreateTopicsResponse 

type MockCreateTopicsResponse = originalSarama.MockCreateTopicsResponse

func NewMockCreateTopicsResponse 

func NewMockCreateTopicsResponse(t TestReporter) *MockCreateTopicsResponse

type MockDeleteAclsResponse 

type MockDeleteAclsResponse = originalSarama.MockDeleteAclsResponse

func NewMockDeleteAclsResponse 

func NewMockDeleteAclsResponse(t TestReporter) *MockDeleteAclsResponse

type MockDeleteGroupsResponse 

type MockDeleteGroupsResponse = originalSarama.MockDeleteGroupsResponse

func NewMockDeleteGroupsRequest 

func NewMockDeleteGroupsRequest(t TestReporter) *MockDeleteGroupsResponse

type MockDeleteOffsetResponse 

type MockDeleteOffsetResponse = originalSarama.MockDeleteOffsetResponse

func NewMockDeleteOffsetRequest 

func NewMockDeleteOffsetRequest(t TestReporter) *MockDeleteOffsetResponse

type MockDeleteRecordsResponse 

type MockDeleteRecordsResponse = originalSarama.MockDeleteRecordsResponse

func NewMockDeleteRecordsResponse 

func NewMockDeleteRecordsResponse(t TestReporter) *MockDeleteRecordsResponse

type MockDeleteTopicsResponse 

type MockDeleteTopicsResponse = originalSarama.MockDeleteTopicsResponse

func NewMockDeleteTopicsResponse 

func NewMockDeleteTopicsResponse(t TestReporter) *MockDeleteTopicsResponse

type MockDescribeConfigsResponse 

type MockDescribeConfigsResponse = originalSarama.MockDescribeConfigsResponse

func NewMockDescribeConfigsResponse 

func NewMockDescribeConfigsResponse(t TestReporter) *MockDescribeConfigsResponse

type MockDescribeConfigsResponseWithErrorCode 

type MockDescribeConfigsResponseWithErrorCode = originalSarama.MockDescribeConfigsResponseWithErrorCode

func NewMockDescribeConfigsResponseWithErrorCode 

func NewMockDescribeConfigsResponseWithErrorCode(t TestReporter) *MockDescribeConfigsResponseWithErrorCode

type MockDescribeGroupsResponse 

type MockDescribeGroupsResponse = originalSarama.MockDescribeGroupsResponse

func NewMockDescribeGroupsResponse 

func NewMockDescribeGroupsResponse(t TestReporter) *MockDescribeGroupsResponse

type MockDescribeLogDirsResponse 

type MockDescribeLogDirsResponse = originalSarama.MockDescribeLogDirsResponse

func NewMockDescribeLogDirsResponse 

func NewMockDescribeLogDirsResponse(t TestReporter) *MockDescribeLogDirsResponse

type MockFetchResponse 

type MockFetchResponse = originalSarama.MockFetchResponse

func NewMockFetchResponse 

func NewMockFetchResponse(t TestReporter, batchSize int) *MockFetchResponse

type MockFindCoordinatorResponse 

type MockFindCoordinatorResponse = originalSarama.MockFindCoordinatorResponse

func NewMockFindCoordinatorResponse 

func NewMockFindCoordinatorResponse(t TestReporter) *MockFindCoordinatorResponse

type MockHeartbeatResponse 

type MockHeartbeatResponse = originalSarama.MockHeartbeatResponse

func NewMockHeartbeatResponse 

func NewMockHeartbeatResponse(t TestReporter) *MockHeartbeatResponse

type MockIncrementalAlterConfigsResponse 

type MockIncrementalAlterConfigsResponse = originalSarama.MockIncrementalAlterConfigsResponse

func NewMockIncrementalAlterConfigsResponse 

func NewMockIncrementalAlterConfigsResponse(t TestReporter) *MockIncrementalAlterConfigsResponse

type MockIncrementalAlterConfigsResponseWithErrorCode 

type MockIncrementalAlterConfigsResponseWithErrorCode = originalSarama.MockIncrementalAlterConfigsResponseWithErrorCode

func NewMockIncrementalAlterConfigsResponseWithErrorCode 

func NewMockIncrementalAlterConfigsResponseWithErrorCode(t TestReporter) *MockIncrementalAlterConfigsResponseWithErrorCode

type MockJoinGroupResponse 

type MockJoinGroupResponse = originalSarama.MockJoinGroupResponse

func NewMockJoinGroupResponse 

func NewMockJoinGroupResponse(t TestReporter) *MockJoinGroupResponse

type MockKerberosClient 

type MockKerberosClient = originalSarama.MockKerberosClient

type MockLeaveGroupResponse 

type MockLeaveGroupResponse = originalSarama.MockLeaveGroupResponse

func NewMockLeaveGroupResponse 

func NewMockLeaveGroupResponse(t TestReporter) *MockLeaveGroupResponse

type MockListAclsResponse 

type MockListAclsResponse = originalSarama.MockListAclsResponse

func NewMockListAclsResponse 

func NewMockListAclsResponse(t TestReporter) *MockListAclsResponse

type MockListGroupsResponse 

type MockListGroupsResponse = originalSarama.MockListGroupsResponse

func NewMockListGroupsResponse 

func NewMockListGroupsResponse(t TestReporter) *MockListGroupsResponse

type MockListPartitionReassignmentsResponse 

type MockListPartitionReassignmentsResponse = originalSarama.MockListPartitionReassignmentsResponse

func NewMockListPartitionReassignmentsResponse 

func NewMockListPartitionReassignmentsResponse(t TestReporter) *MockListPartitionReassignmentsResponse

type MockMetadataResponse 

type MockMetadataResponse = originalSarama.MockMetadataResponse

func NewMockMetadataResponse 

func NewMockMetadataResponse(t TestReporter) *MockMetadataResponse

type MockOffsetCommitResponse 

type MockOffsetCommitResponse = originalSarama.MockOffsetCommitResponse

func NewMockOffsetCommitResponse 

func NewMockOffsetCommitResponse(t TestReporter) *MockOffsetCommitResponse

type MockOffsetFetchResponse 

type MockOffsetFetchResponse = originalSarama.MockOffsetFetchResponse

func NewMockOffsetFetchResponse 

func NewMockOffsetFetchResponse(t TestReporter) *MockOffsetFetchResponse

type MockOffsetResponse 

type MockOffsetResponse = originalSarama.MockOffsetResponse

func NewMockOffsetResponse 

func NewMockOffsetResponse(t TestReporter) *MockOffsetResponse

type MockProduceResponse 

type MockProduceResponse = originalSarama.MockProduceResponse

func NewMockProduceResponse 

func NewMockProduceResponse(t TestReporter) *MockProduceResponse

type MockResponse 

type MockResponse = originalSarama.MockResponse

type MockSaslAuthenticateResponse 

type MockSaslAuthenticateResponse = originalSarama.MockSaslAuthenticateResponse

func NewMockSaslAuthenticateResponse 

func NewMockSaslAuthenticateResponse(t TestReporter) *MockSaslAuthenticateResponse

type MockSaslHandshakeResponse 

type MockSaslHandshakeResponse = originalSarama.MockSaslHandshakeResponse

func NewMockSaslHandshakeResponse 

func NewMockSaslHandshakeResponse(t TestReporter) *MockSaslHandshakeResponse

type MockSequence 

type MockSequence = originalSarama.MockSequence

func NewMockSequence 

func NewMockSequence(responses ...interface{}) *MockSequence

type MockSyncGroupResponse 

type MockSyncGroupResponse = originalSarama.MockSyncGroupResponse

func NewMockSyncGroupResponse 

func NewMockSyncGroupResponse(t TestReporter) *MockSyncGroupResponse

type MockWrapper 

type MockWrapper = originalSarama.MockWrapper

type OffsetCommitRequest 

type OffsetCommitRequest = originalSarama.OffsetCommitRequest

type OffsetCommitResponse 

type OffsetCommitResponse = originalSarama.OffsetCommitResponse

type OffsetFetchRequest 

type OffsetFetchRequest = originalSarama.OffsetFetchRequest

type OffsetFetchResponse 

type OffsetFetchResponse = originalSarama.OffsetFetchResponse

type OffsetFetchResponseBlock 

type OffsetFetchResponseBlock = originalSarama.OffsetFetchResponseBlock

type OffsetManager 

type OffsetManager = originalSarama.OffsetManager

func NewOffsetManagerFromClient 

func NewOffsetManagerFromClient(group string, client Client) (OffsetManager, error)

type OffsetRequest 

type OffsetRequest = originalSarama.OffsetRequest

type OffsetResponse 

type OffsetResponse = originalSarama.OffsetResponse

type OffsetResponseBlock 

type OffsetResponseBlock = originalSarama.OffsetResponseBlock

type OwnedPartition 

type OwnedPartition = originalSarama.OwnedPartition

type PacketDecodingError 

type PacketDecodingError = originalSarama.PacketDecodingError

type PacketEncodingError 

type PacketEncodingError = originalSarama.PacketEncodingError

type PartitionConsumer 

type PartitionConsumer = originalSarama.PartitionConsumer

type PartitionError 

type PartitionError = originalSarama.PartitionError

type PartitionMetadata 

type PartitionMetadata = originalSarama.PartitionMetadata

type PartitionOffsetManager 

type PartitionOffsetManager = originalSarama.PartitionOffsetManager

type PartitionOffsetMetadata 

type PartitionOffsetMetadata = originalSarama.PartitionOffsetMetadata

type PartitionReplicaReassignmentsStatus 

type PartitionReplicaReassignmentsStatus = originalSarama.PartitionReplicaReassignmentsStatus

type Partitioner 

type Partitioner = originalSarama.Partitioner

func NewHashPartitioner 

func NewHashPartitioner(topic string) Partitioner

func NewManualPartitioner 

func NewManualPartitioner(topic string) Partitioner

func NewRandomPartitioner 

func NewRandomPartitioner(topic string) Partitioner

func NewReferenceHashPartitioner 

func NewReferenceHashPartitioner(topic string) Partitioner

func NewRoundRobinPartitioner 

func NewRoundRobinPartitioner(topic string) Partitioner

type PartitionerConstructor 

type PartitionerConstructor = originalSarama.PartitionerConstructor

func NewCustomHashPartitioner 

func NewCustomHashPartitioner(hasher func() hash.Hash32) PartitionerConstructor

func NewCustomPartitioner 

func NewCustomPartitioner(options ...HashPartitionerOption) PartitionerConstructor

type ProduceCallback 

type ProduceCallback = originalSarama.ProduceCallback

type ProduceRequest 

type ProduceRequest = originalSarama.ProduceRequest

type ProduceResponse 

type ProduceResponse = originalSarama.ProduceResponse

type ProduceResponseBlock 

type ProduceResponseBlock = originalSarama.ProduceResponseBlock

type ProducerError 

type ProducerError = originalSarama.ProducerError

type ProducerErrors 

type ProducerErrors = originalSarama.ProducerErrors

type ProducerInterceptor 

type ProducerInterceptor = originalSarama.ProducerInterceptor

type ProducerMessage 

type ProducerMessage = originalSarama.ProducerMessage

type ProducerTxnStatusFlag 

type ProducerTxnStatusFlag = originalSarama.ProducerTxnStatusFlag

type QuotaEntityComponent 

type QuotaEntityComponent = originalSarama.QuotaEntityComponent

type QuotaEntityType 

type QuotaEntityType = originalSarama.QuotaEntityType

type QuotaFilterComponent 

type QuotaFilterComponent = originalSarama.QuotaFilterComponent

type QuotaMatchType 

type QuotaMatchType = originalSarama.QuotaMatchType

type Record 

type Record = originalSarama.Record

type RecordBatch 

type RecordBatch = originalSarama.RecordBatch

type RecordHeader 

type RecordHeader = originalSarama.RecordHeader

type Records 

type Records = originalSarama.Records

type RequestNotifierFunc 

type RequestNotifierFunc = originalSarama.RequestNotifierFunc

type RequestResponse 

type RequestResponse = originalSarama.RequestResponse

type RequiredAcks 

type RequiredAcks = originalSarama.RequiredAcks

type Resource 

type Resource = originalSarama.Resource

type ResourceAcls 

type ResourceAcls = originalSarama.ResourceAcls

type ResourceResponse 

type ResourceResponse = originalSarama.ResourceResponse

type SASLMechanism 

type SASLMechanism = originalSarama.SASLMechanism

type SCRAMClient 

type SCRAMClient = originalSarama.SCRAMClient

type SaslAuthenticateRequest 

type SaslAuthenticateRequest = originalSarama.SaslAuthenticateRequest

type SaslAuthenticateResponse 

type SaslAuthenticateResponse = originalSarama.SaslAuthenticateResponse

type SaslHandshakeRequest 

type SaslHandshakeRequest = originalSarama.SaslHandshakeRequest

type SaslHandshakeResponse 

type SaslHandshakeResponse = originalSarama.SaslHandshakeResponse

type ScramMechanismType 

type ScramMechanismType = originalSarama.ScramMechanismType

type StdLogger 

type StdLogger = originalSarama.StdLogger

type StickyAssignorUserData 

type StickyAssignorUserData = originalSarama.StickyAssignorUserData

type StickyAssignorUserDataV0 

type StickyAssignorUserDataV0 = originalSarama.StickyAssignorUserDataV0

type StickyAssignorUserDataV1 

type StickyAssignorUserDataV1 = originalSarama.StickyAssignorUserDataV1

type StringEncoder 

type StringEncoder = originalSarama.StringEncoder

type SyncGroupRequest 

type SyncGroupRequest = originalSarama.SyncGroupRequest

type SyncGroupRequestAssignment 

type SyncGroupRequestAssignment = originalSarama.SyncGroupRequestAssignment

type SyncGroupResponse 

type SyncGroupResponse = originalSarama.SyncGroupResponse

type SyncProducer 

type SyncProducer = originalSarama.SyncProducer

func NewSyncProducer 

func NewSyncProducer(addrs []string, config *Config) (SyncProducer, error)

func NewSyncProducerFromClient 

func NewSyncProducerFromClient(client Client) (SyncProducer, error)

type TestReporter 

type TestReporter = originalSarama.TestReporter

type Timestamp 

type Timestamp = originalSarama.Timestamp

type TopicDetail 

type TopicDetail = originalSarama.TopicDetail

type TopicError 

type TopicError = originalSarama.TopicError

type TopicMetadata 

type TopicMetadata = originalSarama.TopicMetadata

type TopicPartition 

type TopicPartition = originalSarama.TopicPartition

type TopicPartitionError 

type TopicPartitionError = originalSarama.TopicPartitionError

type TxnOffsetCommitRequest 

type TxnOffsetCommitRequest = originalSarama.TxnOffsetCommitRequest

type TxnOffsetCommitResponse 

type TxnOffsetCommitResponse = originalSarama.TxnOffsetCommitResponse

type UserScramCredentialsResponseInfo 

type UserScramCredentialsResponseInfo = originalSarama.UserScramCredentialsResponseInfo

type ZstdDecoderParams 

type ZstdDecoderParams = originalSarama.ZstdDecoderParams

type ZstdEncoderParams 

type ZstdEncoderParams = originalSarama.ZstdEncoderParams

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.