heliossarama

Documentation

Index

• Constants
• Variables
• func InjectContextToMessage(ctx context.Context, message *originalSarama.ProducerMessage)
• func Wrap(sentinel error, wrapped ...error) interface{}
• type AbortedTransaction
• type AccessToken
• type AccessTokenProvider
• type Acl
• type AclCreation
• type AclCreationResponse
• type AclFilter
• type AclOperation
• type AclPermissionType
• type AclResourcePatternType
• type AclResourceType
• type AddOffsetsToTxnRequest
• type AddOffsetsToTxnResponse
• type AddPartitionsToTxnRequest
• type AddPartitionsToTxnResponse
• type AlterClientQuotasEntry
• type AlterClientQuotasEntryResponse
• type AlterClientQuotasRequest
• type AlterClientQuotasResponse
• type AlterConfigsRequest
• type AlterConfigsResource
• type AlterConfigsResourceResponse
• type AlterConfigsResponse
• type AlterPartitionReassignmentsRequest
• type AlterPartitionReassignmentsResponse
• type AlterUserScramCredentialsDelete
• type AlterUserScramCredentialsRequest
• type AlterUserScramCredentialsResponse
• type AlterUserScramCredentialsResult
• type AlterUserScramCredentialsUpsert
• type ApiVersionsRequest
• type ApiVersionsResponse
• type ApiVersionsResponseKey
• type AsyncProducer
  • func NewAsyncProducer(addrs []string, conf *Config) (AsyncProducer, error)
  • func NewAsyncProducerFromClient(client Client) (AsyncProducer, error)
• type BalanceStrategy
• type BalanceStrategyPlan
• type Broker
  • func NewBroker(addr string) *Broker
• type ByteEncoder
• type Client
  • func NewClient(addrs []string, conf *Config) (Client, error)
• type ClientQuotasOp
• type ClusterAdmin
  • func NewClusterAdmin(addrs []string, conf *Config) (ClusterAdmin, error)
  • func NewClusterAdminFromClient(client Client) (ClusterAdmin, error)
• type CompressionCodec
• type Config
  • func NewConfig() *Config
• type ConfigEntry
• type ConfigResource
• type ConfigResourceType
• type ConfigSource
• type ConfigSynonym
• type ConfigurationError
• type Consumer
  • func NewConsumer(addrs []string, config *Config) (Consumer, error)
  • func NewConsumerFromClient(client Client) (Consumer, error)
• type ConsumerError
• type ConsumerErrors
• type ConsumerGroup
  • func NewConsumerGroup(addrs []string, groupID string, config *Config) (ConsumerGroup, error)
  • func NewConsumerGroupFromClient(groupID string, client Client) (ConsumerGroup, error)
• type ConsumerGroupClaim
• type ConsumerGroupHandler
• type ConsumerGroupMemberAssignment
• type ConsumerGroupMemberMetadata
• type ConsumerGroupSession
• type ConsumerInterceptor
• type ConsumerMessage
• type ConsumerMetadataRequest
• type ConsumerMetadataResponse
• type ControlRecord
• type ControlRecordType
• type CoordinatorType
• type CreateAclsRequest
• type CreateAclsResponse
• type CreatePartitionsRequest
• type CreatePartitionsResponse
• type CreateTopicsRequest
• type CreateTopicsResponse
• type DeleteAclsRequest
• type DeleteAclsResponse
• type DeleteGroupsRequest
• type DeleteGroupsResponse
• type DeleteOffsetsRequest
• type DeleteOffsetsResponse
• type DeleteRecordsRequest
• type DeleteRecordsRequestTopic
• type DeleteRecordsResponse
• type DeleteRecordsResponsePartition
• type DeleteRecordsResponseTopic
• type DeleteTopicsRequest
• type DeleteTopicsResponse
• type DescribeAclsRequest
• type DescribeAclsResponse
• type DescribeClientQuotasEntry
• type DescribeClientQuotasRequest
• type DescribeClientQuotasResponse
• type DescribeConfigsRequest
• type DescribeConfigsResponse
• type DescribeGroupsRequest
• type DescribeGroupsResponse
• type DescribeLogDirsRequest
• type DescribeLogDirsRequestTopic
• type DescribeLogDirsResponse
• type DescribeLogDirsResponseDirMetadata
• type DescribeLogDirsResponsePartition
• type DescribeLogDirsResponseTopic
• type DescribeUserScramCredentialsRequest
• type DescribeUserScramCredentialsRequestUser
• type DescribeUserScramCredentialsResponse
• type DescribeUserScramCredentialsResult
• type DynamicConsistencyPartitioner
• type Encoder
• type EndTxnRequest
• type EndTxnResponse
• type FetchRequest
• type FetchResponse
• type FetchResponseBlock
• type FilterResponse
• type FindCoordinatorRequest
• type FindCoordinatorResponse
• type GSSAPIConfig
• type GSSAPIKerberosAuth
• type GSSApiHandlerFunc
• type GroupDescription
• type GroupMember
• type GroupMemberDescription
• type GroupProtocol
• type HashPartitionerOption
  • func WithAbsFirst() HashPartitionerOption
  • func WithCustomFallbackPartitioner(randomHP Partitioner) HashPartitionerOption
  • func WithCustomHashFunction(hasher func() hash.Hash32) HashPartitionerOption
• type HeartbeatRequest
• type HeartbeatResponse
• type IncrementalAlterConfigsEntry
• type IncrementalAlterConfigsOperation
• type IncrementalAlterConfigsRequest
• type IncrementalAlterConfigsResource
• type IncrementalAlterConfigsResponse
• type InitProducerIDRequest
• type InitProducerIDResponse
• type IsolationLevel
• type JoinGroupRequest
• type JoinGroupResponse
• type KError
• type KafkaGSSAPIHandler
• type KafkaVersion
  • func ParseKafkaVersion(s string) (KafkaVersion, error)
• type KerberosClient
  • func NewKerberosClient(config *GSSAPIConfig) (KerberosClient, error)
• type KerberosGoKrb5Client
• type LeaveGroupRequest
• type LeaveGroupResponse
• type ListGroupsRequest
• type ListGroupsResponse
• type ListPartitionReassignmentsRequest
• type ListPartitionReassignmentsResponse
• type MatchingAcl
• type MemberIdentity
• type MemberResponse
• type Message
• type MessageBlock
• type MessageSet
• type MetadataRequest
• type MetadataResponse
• type MockAlterConfigsResponse
  • func NewMockAlterConfigsResponse(t TestReporter) *MockAlterConfigsResponse
• type MockAlterConfigsResponseWithErrorCode
  • func NewMockAlterConfigsResponseWithErrorCode(t TestReporter) *MockAlterConfigsResponseWithErrorCode
• type MockAlterPartitionReassignmentsResponse
  • func NewMockAlterPartitionReassignmentsResponse(t TestReporter) *MockAlterPartitionReassignmentsResponse
• type MockApiVersionsResponse
  • func NewMockApiVersionsResponse(t TestReporter) *MockApiVersionsResponse
• type MockBroker
  • func NewMockBroker(t TestReporter, brokerID int32) *MockBroker
  • func NewMockBrokerAddr(t TestReporter, brokerID int32, addr string) *MockBroker
  • func NewMockBrokerListener(t TestReporter, brokerID int32, listener net.Listener) *MockBroker
• type MockConsumerMetadataResponse
  • func NewMockConsumerMetadataResponse(t TestReporter) *MockConsumerMetadataResponse
• type MockCreateAclsResponse
  • func NewMockCreateAclsResponse(t TestReporter) *MockCreateAclsResponse
• type MockCreateAclsResponseError
  • func NewMockCreateAclsResponseWithError(t TestReporter) *MockCreateAclsResponseError
• type MockCreatePartitionsResponse
  • func NewMockCreatePartitionsResponse(t TestReporter) *MockCreatePartitionsResponse
• type MockCreateTopicsResponse
  • func NewMockCreateTopicsResponse(t TestReporter) *MockCreateTopicsResponse
• type MockDeleteAclsResponse
  • func NewMockDeleteAclsResponse(t TestReporter) *MockDeleteAclsResponse
• type MockDeleteGroupsResponse
  • func NewMockDeleteGroupsRequest(t TestReporter) *MockDeleteGroupsResponse
• type MockDeleteOffsetResponse
  • func NewMockDeleteOffsetRequest(t TestReporter) *MockDeleteOffsetResponse
• type MockDeleteRecordsResponse
  • func NewMockDeleteRecordsResponse(t TestReporter) *MockDeleteRecordsResponse
• type MockDeleteTopicsResponse
  • func NewMockDeleteTopicsResponse(t TestReporter) *MockDeleteTopicsResponse
• type MockDescribeConfigsResponse
  • func NewMockDescribeConfigsResponse(t TestReporter) *MockDescribeConfigsResponse
• type MockDescribeConfigsResponseWithErrorCode
  • func NewMockDescribeConfigsResponseWithErrorCode(t TestReporter) *MockDescribeConfigsResponseWithErrorCode
• type MockDescribeGroupsResponse
  • func NewMockDescribeGroupsResponse(t TestReporter) *MockDescribeGroupsResponse
• type MockDescribeLogDirsResponse
  • func NewMockDescribeLogDirsResponse(t TestReporter) *MockDescribeLogDirsResponse
• type MockFetchResponse
  • func NewMockFetchResponse(t TestReporter, batchSize int) *MockFetchResponse
• type MockFindCoordinatorResponse
  • func NewMockFindCoordinatorResponse(t TestReporter) *MockFindCoordinatorResponse
• type MockHeartbeatResponse
  • func NewMockHeartbeatResponse(t TestReporter) *MockHeartbeatResponse
• type MockIncrementalAlterConfigsResponse
  • func NewMockIncrementalAlterConfigsResponse(t TestReporter) *MockIncrementalAlterConfigsResponse
• type MockIncrementalAlterConfigsResponseWithErrorCode
  • func NewMockIncrementalAlterConfigsResponseWithErrorCode(t TestReporter) *MockIncrementalAlterConfigsResponseWithErrorCode
• type MockJoinGroupResponse
  • func NewMockJoinGroupResponse(t TestReporter) *MockJoinGroupResponse
• type MockKerberosClient
• type MockLeaveGroupResponse
  • func NewMockLeaveGroupResponse(t TestReporter) *MockLeaveGroupResponse
• type MockListAclsResponse
  • func NewMockListAclsResponse(t TestReporter) *MockListAclsResponse
• type MockListGroupsResponse
  • func NewMockListGroupsResponse(t TestReporter) *MockListGroupsResponse
• type MockListPartitionReassignmentsResponse
  • func NewMockListPartitionReassignmentsResponse(t TestReporter) *MockListPartitionReassignmentsResponse
• type MockMetadataResponse
  • func NewMockMetadataResponse(t TestReporter) *MockMetadataResponse
• type MockOffsetCommitResponse
  • func NewMockOffsetCommitResponse(t TestReporter) *MockOffsetCommitResponse
• type MockOffsetFetchResponse
  • func NewMockOffsetFetchResponse(t TestReporter) *MockOffsetFetchResponse
• type MockOffsetResponse
  • func NewMockOffsetResponse(t TestReporter) *MockOffsetResponse
• type MockProduceResponse
  • func NewMockProduceResponse(t TestReporter) *MockProduceResponse
• type MockResponse
• type MockSaslAuthenticateResponse
  • func NewMockSaslAuthenticateResponse(t TestReporter) *MockSaslAuthenticateResponse
• type MockSaslHandshakeResponse
  • func NewMockSaslHandshakeResponse(t TestReporter) *MockSaslHandshakeResponse
• type MockSequence
  • func NewMockSequence(responses ...interface{}) *MockSequence
• type MockSyncGroupResponse
  • func NewMockSyncGroupResponse(t TestReporter) *MockSyncGroupResponse
• type MockWrapper
• type OffsetCommitRequest
• type OffsetCommitResponse
• type OffsetFetchRequest
• type OffsetFetchResponse
• type OffsetFetchResponseBlock
• type OffsetManager
  • func NewOffsetManagerFromClient(group string, client Client) (OffsetManager, error)
• type OffsetRequest
• type OffsetResponse
• type OffsetResponseBlock
• type OwnedPartition
• type PacketDecodingError
• type PacketEncodingError
• type PartitionConsumer
• type PartitionError
• type PartitionMetadata
• type PartitionOffsetManager
• type PartitionOffsetMetadata
• type PartitionReplicaReassignmentsStatus
• type Partitioner
  • func NewHashPartitioner(topic string) Partitioner
  • func NewManualPartitioner(topic string) Partitioner
  • func NewRandomPartitioner(topic string) Partitioner
  • func NewReferenceHashPartitioner(topic string) Partitioner
  • func NewRoundRobinPartitioner(topic string) Partitioner
• type PartitionerConstructor
  • func NewCustomHashPartitioner(hasher func() hash.Hash32) PartitionerConstructor
  • func NewCustomPartitioner(options ...HashPartitionerOption) PartitionerConstructor
• type ProduceCallback
• type ProduceRequest
• type ProduceResponse
• type ProduceResponseBlock
• type ProducerError
• type ProducerErrors
• type ProducerInterceptor
• type ProducerMessage
• type ProducerTxnStatusFlag
• type QuotaEntityComponent
• type QuotaEntityType
• type QuotaFilterComponent
• type QuotaMatchType
• type Record
• type RecordBatch
• type RecordHeader
• type Records
• type RequestNotifierFunc
• type RequestResponse
• type RequiredAcks
• type Resource
• type ResourceAcls
• type ResourceResponse
• type SASLMechanism
• type SCRAMClient
• type SaslAuthenticateRequest
• type SaslAuthenticateResponse
• type SaslHandshakeRequest
• type SaslHandshakeResponse
• type ScramMechanismType
• type StdLogger
• type StickyAssignorUserData
• type StickyAssignorUserDataV0
• type StickyAssignorUserDataV1
• type StringEncoder
• type SyncGroupRequest
• type SyncGroupRequestAssignment
• type SyncGroupResponse
• type SyncProducer
  • func NewSyncProducer(addrs []string, config *Config) (SyncProducer, error)
  • func NewSyncProducerFromClient(client Client) (SyncProducer, error)
• type TestReporter
• type Timestamp
• type TopicDetail
• type TopicError
• type TopicMetadata
• type TopicPartition
• type TopicPartitionError
• type TxnOffsetCommitRequest
• type TxnOffsetCommitResponse
• type UserScramCredentialsResponseInfo
• type ZstdDecoderParams
• type ZstdEncoderParams

Constants

const APIKeySASLAuth = originalSarama.APIKeySASLAuth

const AclOperationAll = originalSarama.AclOperationAll

const AclOperationAlter = originalSarama.AclOperationAlter

const AclOperationAlterConfigs = originalSarama.AclOperationAlterConfigs

const AclOperationAny = originalSarama.AclOperationAny

const AclOperationClusterAction = originalSarama.AclOperationClusterAction

const AclOperationCreate = originalSarama.AclOperationCreate

const AclOperationDelete = originalSarama.AclOperationDelete

const AclOperationDescribe = originalSarama.AclOperationDescribe

const AclOperationDescribeConfigs = originalSarama.AclOperationDescribeConfigs

const AclOperationIdempotentWrite = originalSarama.AclOperationIdempotentWrite

const AclOperationRead = originalSarama.AclOperationRead

const AclOperationUnknown = originalSarama.AclOperationUnknown

const AclOperationWrite = originalSarama.AclOperationWrite

const AclPatternAny = originalSarama.AclPatternAny

const AclPatternLiteral = originalSarama.AclPatternLiteral

const AclPatternMatch = originalSarama.AclPatternMatch

const AclPatternPrefixed = originalSarama.AclPatternPrefixed

const AclPatternUnknown = originalSarama.AclPatternUnknown

const AclPermissionAllow = originalSarama.AclPermissionAllow

const AclPermissionAny = originalSarama.AclPermissionAny

const AclPermissionDeny = originalSarama.AclPermissionDeny

const AclPermissionUnknown = originalSarama.AclPermissionUnknown

const AclResourceAny = originalSarama.AclResourceAny

const AclResourceCluster = originalSarama.AclResourceCluster

const AclResourceDelegationToken = originalSarama.AclResourceDelegationToken

const AclResourceGroup = originalSarama.AclResourceGroup

const AclResourceTopic = originalSarama.AclResourceTopic

const AclResourceTransactionalID = originalSarama.AclResourceTransactionalID

const AclResourceUnknown = originalSarama.AclResourceUnknown

const BrokerLoggerResource = originalSarama.BrokerLoggerResource

const BrokerResource = originalSarama.BrokerResource

const CompressionGZIP = originalSarama.CompressionGZIP

const CompressionLZ4 = originalSarama.CompressionLZ4

const CompressionLevelDefault = originalSarama.CompressionLevelDefault

const CompressionNone = originalSarama.CompressionNone

const CompressionSnappy = originalSarama.CompressionSnappy

const CompressionZSTD = originalSarama.CompressionZSTD

const ControlRecordAbort = originalSarama.ControlRecordAbort

const ControlRecordCommit = originalSarama.ControlRecordCommit

const ControlRecordUnknown = originalSarama.ControlRecordUnknown

const CoordinatorGroup = originalSarama.CoordinatorGroup

const CoordinatorTransaction = originalSarama.CoordinatorTransaction

const ErrBrokerNotAvailable = originalSarama.ErrBrokerNotAvailable

const ErrClusterAuthorizationFailed = originalSarama.ErrClusterAuthorizationFailed

const ErrConcurrentTransactions = originalSarama.ErrConcurrentTransactions

const ErrConsumerCoordinatorNotAvailable = originalSarama.ErrConsumerCoordinatorNotAvailable

const ErrDelegationTokenAuthDisabled = originalSarama.ErrDelegationTokenAuthDisabled

const ErrDelegationTokenAuthorizationFailed = originalSarama.ErrDelegationTokenAuthorizationFailed

const ErrDelegationTokenExpired = originalSarama.ErrDelegationTokenExpired

const ErrDelegationTokenNotFound = originalSarama.ErrDelegationTokenNotFound

const ErrDelegationTokenOwnerMismatch = originalSarama.ErrDelegationTokenOwnerMismatch

const ErrDelegationTokenRequestNotAllowed = originalSarama.ErrDelegationTokenRequestNotAllowed

const ErrDuplicateSequenceNumber = originalSarama.ErrDuplicateSequenceNumber

const ErrElectionNotNeeded = originalSarama.ErrElectionNotNeeded

const ErrEligibleLeadersNotAvailable = originalSarama.ErrEligibleLeadersNotAvailable

const ErrFencedInstancedId = originalSarama.ErrFencedInstancedId

const ErrFencedLeaderEpoch = originalSarama.ErrFencedLeaderEpoch

const ErrFetchSessionIDNotFound = originalSarama.ErrFetchSessionIDNotFound

const ErrGroupAuthorizationFailed = originalSarama.ErrGroupAuthorizationFailed

const ErrGroupIDNotFound = originalSarama.ErrGroupIDNotFound

const ErrGroupMaxSizeReached = originalSarama.ErrGroupMaxSizeReached

const ErrGroupSubscribedToTopic = originalSarama.ErrGroupSubscribedToTopic

const ErrIllegalGeneration = originalSarama.ErrIllegalGeneration

const ErrIllegalSASLState = originalSarama.ErrIllegalSASLState

const ErrInconsistentGroupProtocol = originalSarama.ErrInconsistentGroupProtocol

const ErrInvalidCommitOffsetSize = originalSarama.ErrInvalidCommitOffsetSize

const ErrInvalidConfig = originalSarama.ErrInvalidConfig

const ErrInvalidFetchSessionEpoch = originalSarama.ErrInvalidFetchSessionEpoch

const ErrInvalidGroupId = originalSarama.ErrInvalidGroupId

const ErrInvalidMessage = originalSarama.ErrInvalidMessage

const ErrInvalidMessageSize = originalSarama.ErrInvalidMessageSize

const ErrInvalidPartitions = originalSarama.ErrInvalidPartitions

const ErrInvalidPrincipalType = originalSarama.ErrInvalidPrincipalType

const ErrInvalidProducerEpoch = originalSarama.ErrInvalidProducerEpoch

const ErrInvalidProducerIDMapping = originalSarama.ErrInvalidProducerIDMapping

const ErrInvalidRecord = originalSarama.ErrInvalidRecord

const ErrInvalidReplicaAssignment = originalSarama.ErrInvalidReplicaAssignment

const ErrInvalidReplicationFactor = originalSarama.ErrInvalidReplicationFactor

const ErrInvalidRequest = originalSarama.ErrInvalidRequest

const ErrInvalidRequiredAcks = originalSarama.ErrInvalidRequiredAcks

const ErrInvalidSessionTimeout = originalSarama.ErrInvalidSessionTimeout

const ErrInvalidTimestamp = originalSarama.ErrInvalidTimestamp

const ErrInvalidTopic = originalSarama.ErrInvalidTopic

const ErrInvalidTransactionTimeout = originalSarama.ErrInvalidTransactionTimeout

const ErrInvalidTxnState = originalSarama.ErrInvalidTxnState

const ErrKafkaStorageError = originalSarama.ErrKafkaStorageError

const ErrLeaderNotAvailable = originalSarama.ErrLeaderNotAvailable

const ErrListenerNotFound = originalSarama.ErrListenerNotFound

const ErrLogDirNotFound = originalSarama.ErrLogDirNotFound

const ErrMemberIdRequired = originalSarama.ErrMemberIdRequired

const ErrMessageSetSizeTooLarge = originalSarama.ErrMessageSetSizeTooLarge

const ErrMessageSizeTooLarge = originalSarama.ErrMessageSizeTooLarge

const ErrNetworkException = originalSarama.ErrNetworkException

const ErrNoError = originalSarama.ErrNoError

const ErrNoReassignmentInProgress = originalSarama.ErrNoReassignmentInProgress

const ErrNonEmptyGroup = originalSarama.ErrNonEmptyGroup

const ErrNotController = originalSarama.ErrNotController

const ErrNotCoordinatorForConsumer = originalSarama.ErrNotCoordinatorForConsumer

const ErrNotEnoughReplicas = originalSarama.ErrNotEnoughReplicas

const ErrNotEnoughReplicasAfterAppend = originalSarama.ErrNotEnoughReplicasAfterAppend

const ErrNotLeaderForPartition = originalSarama.ErrNotLeaderForPartition

const ErrOffsetMetadataTooLarge = originalSarama.ErrOffsetMetadataTooLarge

const ErrOffsetNotAvailable = originalSarama.ErrOffsetNotAvailable

const ErrOffsetOutOfRange = originalSarama.ErrOffsetOutOfRange

const ErrOffsetsLoadInProgress = originalSarama.ErrOffsetsLoadInProgress

const ErrOperationNotAttempted = originalSarama.ErrOperationNotAttempted

const ErrOutOfOrderSequenceNumber = originalSarama.ErrOutOfOrderSequenceNumber

const ErrPolicyViolation = originalSarama.ErrPolicyViolation

const ErrPreferredLeaderNotAvailable = originalSarama.ErrPreferredLeaderNotAvailable

const ErrProducerFenced = originalSarama.ErrProducerFenced

const ErrReassignmentInProgress = originalSarama.ErrReassignmentInProgress

const ErrRebalanceInProgress = originalSarama.ErrRebalanceInProgress

const ErrReplicaNotAvailable = originalSarama.ErrReplicaNotAvailable

const ErrRequestTimedOut = originalSarama.ErrRequestTimedOut

const ErrSASLAuthenticationFailed = originalSarama.ErrSASLAuthenticationFailed

const ErrSecurityDisabled = originalSarama.ErrSecurityDisabled

const ErrStaleBrokerEpoch = originalSarama.ErrStaleBrokerEpoch

const ErrStaleControllerEpochCode = originalSarama.ErrStaleControllerEpochCode

const ErrThrottlingQuotaExceeded = originalSarama.ErrThrottlingQuotaExceeded

const ErrTopicAlreadyExists = originalSarama.ErrTopicAlreadyExists

const ErrTopicAuthorizationFailed = originalSarama.ErrTopicAuthorizationFailed

const ErrTopicDeletionDisabled = originalSarama.ErrTopicDeletionDisabled

const ErrTransactionCoordinatorFenced = originalSarama.ErrTransactionCoordinatorFenced

const ErrTransactionalIDAuthorizationFailed = originalSarama.ErrTransactionalIDAuthorizationFailed

const ErrUnknown = originalSarama.ErrUnknown

const ErrUnknownLeaderEpoch = originalSarama.ErrUnknownLeaderEpoch

const ErrUnknownMemberId = originalSarama.ErrUnknownMemberId

const ErrUnknownProducerID = originalSarama.ErrUnknownProducerID

const ErrUnknownTopicOrPartition = originalSarama.ErrUnknownTopicOrPartition

const ErrUnstableOffsetCommit = originalSarama.ErrUnstableOffsetCommit

const ErrUnsupportedCompressionType = originalSarama.ErrUnsupportedCompressionType

const ErrUnsupportedForMessageFormat = originalSarama.ErrUnsupportedForMessageFormat

const ErrUnsupportedSASLMechanism = originalSarama.ErrUnsupportedSASLMechanism

const ErrUnsupportedVersion = originalSarama.ErrUnsupportedVersion

const GSS_API_FINISH = originalSarama.GSS_API_FINISH

const GSS_API_GENERIC_TAG = originalSarama.GSS_API_GENERIC_TAG

const GSS_API_INITIAL = originalSarama.GSS_API_INITIAL

const GSS_API_VERIFY = originalSarama.GSS_API_VERIFY

const GroupGenerationUndefined = originalSarama.GroupGenerationUndefined

const IncrementalAlterConfigsOperationAppend = originalSarama.IncrementalAlterConfigsOperationAppend

const IncrementalAlterConfigsOperationDelete = originalSarama.IncrementalAlterConfigsOperationDelete

const IncrementalAlterConfigsOperationSet = originalSarama.IncrementalAlterConfigsOperationSet

const IncrementalAlterConfigsOperationSubtract = originalSarama.IncrementalAlterConfigsOperationSubtract

const KRB5_KEYTAB_AUTH = originalSarama.KRB5_KEYTAB_AUTH

const KRB5_USER_AUTH = originalSarama.KRB5_USER_AUTH

const MAX_GROUP_INSTANCE_ID_LENGTH = originalSarama.MAX_GROUP_INSTANCE_ID_LENGTH

const NoResponse = originalSarama.NoResponse

const OffsetNewest = originalSarama.OffsetNewest

const OffsetOldest = originalSarama.OffsetOldest

const ProducerTxnFlagAbortableError = originalSarama.ProducerTxnFlagAbortableError

const ProducerTxnFlagAbortingTransaction = originalSarama.ProducerTxnFlagAbortingTransaction

const ProducerTxnFlagCommittingTransaction = originalSarama.ProducerTxnFlagCommittingTransaction

const ProducerTxnFlagEndTransaction = originalSarama.ProducerTxnFlagEndTransaction

const ProducerTxnFlagFatalError = originalSarama.ProducerTxnFlagFatalError

const ProducerTxnFlagInError = originalSarama.ProducerTxnFlagInError

const ProducerTxnFlagInTransaction = originalSarama.ProducerTxnFlagInTransaction

const ProducerTxnFlagInitializing = originalSarama.ProducerTxnFlagInitializing

const ProducerTxnFlagReady = originalSarama.ProducerTxnFlagReady

const ProducerTxnFlagUninitialized = originalSarama.ProducerTxnFlagUninitialized

const QuotaEntityClientID = originalSarama.QuotaEntityClientID

const QuotaEntityIP = originalSarama.QuotaEntityIP

const QuotaEntityUser = originalSarama.QuotaEntityUser

const QuotaMatchAny = originalSarama.QuotaMatchAny

const QuotaMatchDefault = originalSarama.QuotaMatchDefault

const QuotaMatchExact = originalSarama.QuotaMatchExact

const RangeBalanceStrategyName = originalSarama.RangeBalanceStrategyName

const ReadCommitted = originalSarama.ReadCommitted

const ReadUncommitted = originalSarama.ReadUncommitted

const ReceiveTime = originalSarama.ReceiveTime

const RoundRobinBalanceStrategyName = originalSarama.RoundRobinBalanceStrategyName

const SASLExtKeyAuth = originalSarama.SASLExtKeyAuth

const SASLHandshakeV0 = originalSarama.SASLHandshakeV0

const SASLHandshakeV1 = originalSarama.SASLHandshakeV1

const SASLTypeGSSAPI = originalSarama.SASLTypeGSSAPI

const SASLTypeOAuth = originalSarama.SASLTypeOAuth

const SASLTypePlaintext = originalSarama.SASLTypePlaintext

const SASLTypeSCRAMSHA256 = originalSarama.SASLTypeSCRAMSHA256

const SASLTypeSCRAMSHA512 = originalSarama.SASLTypeSCRAMSHA512

const SCRAM_MECHANISM_SHA_256 = originalSarama.SCRAM_MECHANISM_SHA_256

const SCRAM_MECHANISM_SHA_512 = originalSarama.SCRAM_MECHANISM_SHA_512

const SCRAM_MECHANISM_UNKNOWN = originalSarama.SCRAM_MECHANISM_UNKNOWN

const SourceDefault = originalSarama.SourceDefault

const SourceDynamicBroker = originalSarama.SourceDynamicBroker

const SourceDynamicDefaultBroker = originalSarama.SourceDynamicDefaultBroker

const SourceStaticBroker = originalSarama.SourceStaticBroker

const SourceTopic = originalSarama.SourceTopic

const SourceUnknown = originalSarama.SourceUnknown

const StickyBalanceStrategyName = originalSarama.StickyBalanceStrategyName

const TOK_ID_KRB_AP_REQ = originalSarama.TOK_ID_KRB_AP_REQ

const TopicResource = originalSarama.TopicResource

const UnknownResource = originalSarama.UnknownResource

const WaitForAll = originalSarama.WaitForAll

const WaitForLocal = originalSarama.WaitForLocal

Variables

var BalanceStrategyRange = originalSarama.BalanceStrategyRange

var BalanceStrategyRoundRobin = originalSarama.BalanceStrategyRoundRobin

var BalanceStrategySticky = originalSarama.BalanceStrategySticky

var DebugLogger = originalSarama.DebugLogger

var DefaultVersion = originalSarama.DefaultVersion

var ErrAddPartitionsToTxn = originalSarama.ErrAddPartitionsToTxn

var ErrAlreadyConnected = originalSarama.ErrAlreadyConnected

var ErrBrokerNotFound = originalSarama.ErrBrokerNotFound

var ErrCannotTransitionNilError = originalSarama.ErrCannotTransitionNilError

var ErrClosedClient = originalSarama.ErrClosedClient

var ErrClosedConsumerGroup = originalSarama.ErrClosedConsumerGroup

var ErrConsumerOffsetNotAdvanced = originalSarama.ErrConsumerOffsetNotAdvanced

var ErrControllerNotAvailable = originalSarama.ErrControllerNotAvailable

var ErrCreateACLs = originalSarama.ErrCreateACLs

var ErrDeleteRecords = originalSarama.ErrDeleteRecords

var ErrIncompleteResponse = originalSarama.ErrIncompleteResponse

var ErrInsufficientData = originalSarama.ErrInsufficientData

var ErrInvalidPartition = originalSarama.ErrInvalidPartition

var ErrMessageTooLarge = originalSarama.ErrMessageTooLarge

var ErrNoTopicsToUpdateMetadata = originalSarama.ErrNoTopicsToUpdateMetadata

var ErrNonTransactedProducer = originalSarama.ErrNonTransactedProducer

var ErrNotConnected = originalSarama.ErrNotConnected

var ErrOutOfBrokers = originalSarama.ErrOutOfBrokers

var ErrReassignPartitions = originalSarama.ErrReassignPartitions

var ErrShuttingDown = originalSarama.ErrShuttingDown

var ErrTransactionNotReady = originalSarama.ErrTransactionNotReady

var ErrTransitionNotAllowed = originalSarama.ErrTransitionNotAllowed

var ErrTxnOffsetCommit = originalSarama.ErrTxnOffsetCommit

var ErrTxnUnableToParseResponse = originalSarama.ErrTxnUnableToParseResponse

var ErrUnknownScramMechanism = originalSarama.ErrUnknownScramMechanism

var GROUP_INSTANCE_ID_REGEXP = originalSarama.GROUP_INSTANCE_ID_REGEXP

var Logger = originalSarama.Logger

var MaxRequestSize = originalSarama.MaxRequestSize

var MaxResponseSize = originalSarama.MaxResponseSize

var MaxVersion = originalSarama.MaxVersion

var MinVersion = originalSarama.MinVersion

var MultiErrorFormat = originalSarama.MultiErrorFormat

var NoNode = originalSarama.NoNode

var PanicHandler = originalSarama.PanicHandler

var SupportedVersions = originalSarama.SupportedVersions

var V0_10_0_0 = originalSarama.V0_10_0_0

var V0_10_0_1 = originalSarama.V0_10_0_1

var V0_10_1_0 = originalSarama.V0_10_1_0

var V0_10_1_1 = originalSarama.V0_10_1_1

var V0_10_2_0 = originalSarama.V0_10_2_0

var V0_10_2_1 = originalSarama.V0_10_2_1

var V0_10_2_2 = originalSarama.V0_10_2_2

var V0_11_0_0 = originalSarama.V0_11_0_0

var V0_11_0_1 = originalSarama.V0_11_0_1

var V0_11_0_2 = originalSarama.V0_11_0_2

var V0_8_2_0 = originalSarama.V0_8_2_0

var V0_8_2_1 = originalSarama.V0_8_2_1

var V0_8_2_2 = originalSarama.V0_8_2_2

var V0_9_0_0 = originalSarama.V0_9_0_0

var V0_9_0_1 = originalSarama.V0_9_0_1

var V1_0_0_0 = originalSarama.V1_0_0_0

var V1_0_1_0 = originalSarama.V1_0_1_0

var V1_0_2_0 = originalSarama.V1_0_2_0

var V1_1_0_0 = originalSarama.V1_1_0_0

var V1_1_1_0 = originalSarama.V1_1_1_0

var V2_0_0_0 = originalSarama.V2_0_0_0

var V2_0_1_0 = originalSarama.V2_0_1_0

var V2_1_0_0 = originalSarama.V2_1_0_0

var V2_1_1_0 = originalSarama.V2_1_1_0

var V2_2_0_0 = originalSarama.V2_2_0_0

var V2_2_1_0 = originalSarama.V2_2_1_0

var V2_2_2_0 = originalSarama.V2_2_2_0

var V2_3_0_0 = originalSarama.V2_3_0_0

var V2_3_1_0 = originalSarama.V2_3_1_0

var V2_4_0_0 = originalSarama.V2_4_0_0

var V2_4_1_0 = originalSarama.V2_4_1_0

var V2_5_0_0 = originalSarama.V2_5_0_0

var V2_5_1_0 = originalSarama.V2_5_1_0

var V2_6_0_0 = originalSarama.V2_6_0_0

var V2_6_1_0 = originalSarama.V2_6_1_0

var V2_6_2_0 = originalSarama.V2_6_2_0

var V2_6_3_0 = originalSarama.V2_6_3_0

var V2_7_0_0 = originalSarama.V2_7_0_0

var V2_7_1_0 = originalSarama.V2_7_1_0

var V2_7_2_0 = originalSarama.V2_7_2_0

var V2_8_0_0 = originalSarama.V2_8_0_0

var V2_8_1_0 = originalSarama.V2_8_1_0

var V2_8_2_0 = originalSarama.V2_8_2_0

var V3_0_0_0 = originalSarama.V3_0_0_0

var V3_0_1_0 = originalSarama.V3_0_1_0

var V3_0_2_0 = originalSarama.V3_0_2_0

var V3_1_0_0 = originalSarama.V3_1_0_0

var V3_1_1_0 = originalSarama.V3_1_1_0

var V3_1_2_0 = originalSarama.V3_1_2_0

var V3_2_0_0 = originalSarama.V3_2_0_0

var V3_2_1_0 = originalSarama.V3_2_1_0

var V3_2_2_0 = originalSarama.V3_2_2_0

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