Blame - vendor/github.com/confluentinc/confluent-kafka-go/kafka/api.html - voltha-go

<span id="TimestampNotAvailable">TimestampNotAvailable</span> = <a href="#TimestampType">TimestampType</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_TIMESTAMP_NOT_AVAILABLE">RD_KAFKA_TIMESTAMP_NOT_AVAILABLE</a>)

665

<span class="comment">// TimestampCreateTime indicates timestamp set by producer (source time)</span>

666

<span id="TimestampCreateTime">TimestampCreateTime</span> = <a href="#TimestampType">TimestampType</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_TIMESTAMP_CREATE_TIME">RD_KAFKA_TIMESTAMP_CREATE_TIME</a>)

667

<span class="comment">// TimestampLogAppendTime indicates timestamp set set by broker (store time)</span>

668

<span id="TimestampLogAppendTime">TimestampLogAppendTime</span> = <a href="#TimestampType">TimestampType</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_TIMESTAMP_LOG_APPEND_TIME">RD_KAFKA_TIMESTAMP_LOG_APPEND_TIME</a>)

669

)</pre>

670

<pre>const <span id="OffsetBeginning">OffsetBeginning</span> = <a href="#Offset">Offset</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_OFFSET_BEGINNING">RD_KAFKA_OFFSET_BEGINNING</a>)</pre>

671

<p>

672

Earliest offset (logical)

673

</p>

674

<pre>const <span id="OffsetEnd">OffsetEnd</span> = <a href="#Offset">Offset</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_OFFSET_END">RD_KAFKA_OFFSET_END</a>)</pre>

675

<p>

676

Latest offset (logical)

677

</p>

678

<pre>const <span id="OffsetInvalid">OffsetInvalid</span> = <a href="#Offset">Offset</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_OFFSET_INVALID">RD_KAFKA_OFFSET_INVALID</a>)</pre>

679

<p>

680

Invalid/unspecified offset

681

</p>

682

<pre>const <span id="OffsetStored">OffsetStored</span> = <a href="#Offset">Offset</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_OFFSET_STORED">RD_KAFKA_OFFSET_STORED</a>)</pre>

<p>

Use stored offset

</p>

<pre>const <span id="PartitionAny">PartitionAny</span> = <a href="http://golang.org/pkg/builtin/#int32">int32</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_PARTITION_UA">RD_KAFKA_PARTITION_UA</a>)</pre>

687

<p>

688

Any partition (for partitioning), or unspecified value (for all other cases)

</p>

func

LibraryVersion

</a>

</h2>

<pre>func LibraryVersion() (<a href="http://golang.org/pkg/builtin/#int">int</a>, <a href="http://golang.org/pkg/builtin/#string">string</a>)</pre>

697

<p>

698

LibraryVersion returns the underlying librdkafka library version as a

699

(version_int, version_str) tuple.

</p>

type

AssignedPartitions

</a>

</h2>

<pre>type AssignedPartitions struct {

708

Partitions []<a href="#TopicPartition">TopicPartition</a>

709

}</pre>

710

<p>

711

AssignedPartitions consumer group rebalance event: assigned partition set

712

</p>

713

714

func (AssignedPartitions)

String

</a>

</h3>

<pre>func (e <a href="#AssignedPartitions">AssignedPartitions</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

type

BrokerMetadata

</a>

</h2>

<pre>type BrokerMetadata struct {

727

ID <a href="http://golang.org/pkg/builtin/#int32">int32</a>

728

Host <a href="http://golang.org/pkg/builtin/#string">string</a>

729

Port <a href="http://golang.org/pkg/builtin/#int">int</a>

730

}</pre>

731

<p>

732

BrokerMetadata contains per-broker metadata

</p>

type

ConfigMap

</a>

</h2>

<pre>type ConfigMap map[<a href="http://golang.org/pkg/builtin/#string">string</a>]<a href="#ConfigValue">ConfigValue</a></pre>

741

<p>

742

ConfigMap is a map contaning standard librdkafka configuration properties as documented in:

743

744

https://github.com/edenhill/librdkafka/tree/master/CONFIGURATION.md

</a>

</p>

<p>

The special property "default.topic.config" (optional) is a ConfigMap containing default topic

749

configuration properties.

</p>

func (ConfigMap)

Set

</a>

</h3>

<pre>func (m <a href="#ConfigMap">ConfigMap</a>) Set(kv <a href="http://golang.org/pkg/builtin/#string">string</a>) <a href="http://golang.org/pkg/builtin/#error">error</a></pre>

758

<p>

759

Set implements flag.Set (command line argument parser) as a convenience

760

for `-X key=value` config.

</p>

func (ConfigMap)

SetKey

</a>

</h3>

<pre>func (m <a href="#ConfigMap">ConfigMap</a>) SetKey(key <a href="http://golang.org/pkg/builtin/#string">string</a>, value <a href="#ConfigValue">ConfigValue</a>) <a href="http://golang.org/pkg/builtin/#error">error</a></pre>

769

<p>

770

SetKey sets configuration property key to value.

771

For user convenience a key prefixed with {topic}. will be

772

set on the "default.topic.config" sub-map.

</p>

type

ConfigValue

</a>

</h2>

<pre>type ConfigValue interface{}</pre>

781

<p>

782

ConfigValue supports the following types:

783

</p>

784

<pre>bool, int, string, any type with the standard String() interface

</pre>

type

Consumer

</a>

</h2>

<pre>type Consumer struct {

793

<span class="comment">// contains filtered or unexported fields</span>

794

}</pre>

795

<p>

796

Consumer implements a High-level Apache Kafka Consumer instance

</p>

func

NewConsumer

</a>

</h3>

<pre>func NewConsumer(conf *<a href="#ConfigMap">ConfigMap</a>) (*<a href="#Consumer">Consumer</a>, <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

805

<p>

806

NewConsumer creates a new high-level Consumer instance.

807

</p>

808

<p>

809

Supported special configuration properties:

810

</p>

811

<pre>go.application.rebalance.enable (bool, false) - Forward rebalancing responsibility to application via the Events() channel.

812

If set to true the app must handle the AssignedPartitions and

813

RevokedPartitions events and call Assign() and Unassign()

814

respectively.

815

go.events.channel.enable (bool, false) - Enable the Events() channel. Messages and events will be pushed on the Events() channel and the Poll() interface will be disabled. (Experimental)

816

go.events.channel.size (int, 1000) - Events() channel size

817

</pre>

818

<p>

819

WARNING: Due to the buffering nature of channels (and queues in general) the

820

use of the events channel risks receiving outdated events and

821

messages. Minimizing go.events.channel.size reduces the risk

822

and number of outdated events and messages but does not eliminate

823

the factor completely. With a channel size of 1 at most one

824

event or message may be outdated.

</p>

func (*Consumer)

Assign

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) Assign(partitions []<a href="#TopicPartition">TopicPartition</a>) (err <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

833

<p>

834

Assign an atomic set of partitions to consume.

835

This replaces the current assignment.

</p>

func (*Consumer)

Close

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) Close() (err <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

844

<p>

845

Close Consumer instance.

846

The object is no longer usable after this call.

</p>

func (*Consumer)

Commit

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) Commit() ([]<a href="#TopicPartition">TopicPartition</a>, <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

855

<p>

856

Commit offsets for currently assigned partitions

857

This is a blocking call.

858

Returns the committed offsets on success.

</p>

func (*Consumer)

CommitMessage

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) CommitMessage(m *<a href="#Message">Message</a>) ([]<a href="#TopicPartition">TopicPartition</a>, <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

867

<p>

868

CommitMessage commits offset based on the provided message.

869

This is a blocking call.

870

Returns the committed offsets on success.

</p>

func (*Consumer)

CommitOffsets

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) CommitOffsets(offsets []<a href="#TopicPartition">TopicPartition</a>) ([]<a href="#TopicPartition">TopicPartition</a>, <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

879

<p>

880

CommitOffsets commits the provided list of offsets

881

This is a blocking call.

882

Returns the committed offsets on success.

</p>

func (*Consumer)

Events

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) Events() chan <a href="#Event">Event</a></pre>

891

<p>

892

Events returns the Events channel (if enabled)

</p>

func (*Consumer)

GetMetadata

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) GetMetadata(topic *<a href="http://golang.org/pkg/builtin/#string">string</a>, allTopics <a href="http://golang.org/pkg/builtin/#bool">bool</a>, timeoutMs <a href="http://golang.org/pkg/builtin/#int">int</a>) (*<a href="#Metadata">Metadata</a>, <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

901

<p>

902

GetMetadata queries broker for cluster and topic metadata.

903

If topic is non-nil only information about that topic is returned, else if

904

allTopics is false only information about locally used topics is returned,

905

else information about all topics is returned.

</p>

func (*Consumer)

Poll

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) Poll(timeoutMs <a href="http://golang.org/pkg/builtin/#int">int</a>) (event <a href="#Event">Event</a>)</pre>

914

<p>

915

Poll the consumer for messages or events.

916

</p>

917

918

Will block for at most timeoutMs milliseconds

919

</h3>

920

<p>

921

The following callbacks may be triggered:

922

</p>

923

<pre>Subscribe()'s rebalanceCb

924

</pre>

925

<p>

926

Returns nil on timeout, else an Event

</p>

func (*Consumer)

QueryWatermarkOffsets

932

</a>

933

</h3>

934

<pre>func (c *<a href="#Consumer">Consumer</a>) QueryWatermarkOffsets(topic <a href="http://golang.org/pkg/builtin/#string">string</a>, partition <a href="http://golang.org/pkg/builtin/#int32">int32</a>, timeoutMs <a href="http://golang.org/pkg/builtin/#int">int</a>) (low, high <a href="http://golang.org/pkg/builtin/#int64">int64</a>, err <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

935

<p>

936

QueryWatermarkOffsets returns the broker's low and high offsets for the given topic

and partition.

</p>

func (*Consumer)

String

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

946

<p>

947

Strings returns a human readable name for a Consumer instance

</p>

func (*Consumer)

Subscribe

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) Subscribe(topic <a href="http://golang.org/pkg/builtin/#string">string</a>, rebalanceCb <a href="#RebalanceCb">RebalanceCb</a>) <a href="http://golang.org/pkg/builtin/#error">error</a></pre>

956

<p>

957

Subscribe to a single topic

958

This replaces the current subscription

</p>

func (*Consumer)

SubscribeTopics

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) SubscribeTopics(topics []<a href="http://golang.org/pkg/builtin/#string">string</a>, rebalanceCb <a href="#RebalanceCb">RebalanceCb</a>) (err <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

967

<p>

968

SubscribeTopics subscribes to the provided list of topics.

969

This replaces the current subscription.

</p>

func (*Consumer)

Unassign

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) Unassign() (err <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

978

<p>

979

Unassign the current set of partitions to consume.

</p>

func (*Consumer)

Unsubscribe

</a>

</h3>

<pre>func (c *<a href="#Consumer">Consumer</a>) Unsubscribe() (err <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

988

<p>

989

Unsubscribe from the current subscription, if any.

</p>

type

Error

</a>

</h2>

<pre>type Error struct {

998

<span class="comment">// contains filtered or unexported fields</span>

999

}</pre>

1000

<p>

1001

Error provides a Kafka-specific error container

</p>

func (Error)

Code

</a>

</h3>

<pre>func (e <a href="#Error">Error</a>) Code() <a href="#ErrorCode">ErrorCode</a></pre>

1010

<p>

1011

Code returns the ErrorCode of an Error

</p>

func (Error)

Error

</a>

</h3>

<pre>func (e <a href="#Error">Error</a>) Error() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

1020

<p>

1021

Error returns a human readable representation of an Error

1022

Same as Error.String()

</p>

func (Error)

String

</a>

</h3>

<pre>func (e <a href="#Error">Error</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

1031

<p>

1032

String returns a human readable representation of an Error

</p>

type

ErrorCode

</a>

</h2>

<pre>type ErrorCode <a href="http://golang.org/pkg/builtin/#int">int</a></pre>

1041

<p>

1042

ErrorCode is the integer representation of local and broker error codes

1043

</p>

1044

<pre>const (

1045

<span class="comment">// ErrBadMsg Local: Bad message format</span>

1046

<span id="ErrBadMsg">ErrBadMsg</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__BAD_MSG">RD_KAFKA_RESP_ERR__BAD_MSG</a>)

1047

<span class="comment">// ErrBadCompression Local: Invalid compressed data</span>

1048

<span id="ErrBadCompression">ErrBadCompression</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__BAD_COMPRESSION">RD_KAFKA_RESP_ERR__BAD_COMPRESSION</a>)

1049

<span class="comment">// ErrDestroy Local: Broker handle destroyed</span>

1050

<span id="ErrDestroy">ErrDestroy</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__DESTROY">RD_KAFKA_RESP_ERR__DESTROY</a>)

1051

<span class="comment">// ErrFail Local: Communication failure with broker</span>

1052

<span id="ErrFail">ErrFail</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__FAIL">RD_KAFKA_RESP_ERR__FAIL</a>)

1053

<span class="comment">// ErrTransport Local: Broker transport failure</span>

1054

<span id="ErrTransport">ErrTransport</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__TRANSPORT">RD_KAFKA_RESP_ERR__TRANSPORT</a>)

1055

<span class="comment">// ErrCritSysResource Local: Critical system resource failure</span>

1056

<span id="ErrCritSysResource">ErrCritSysResource</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE">RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE</a>)

1057

<span class="comment">// ErrResolve Local: Host resolution failure</span>

1058

<span id="ErrResolve">ErrResolve</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__RESOLVE">RD_KAFKA_RESP_ERR__RESOLVE</a>)

1059

<span class="comment">// ErrMsgTimedOut Local: Message timed out</span>

1060

<span id="ErrMsgTimedOut">ErrMsgTimedOut</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__MSG_TIMED_OUT">RD_KAFKA_RESP_ERR__MSG_TIMED_OUT</a>)

1061

<span class="comment">// ErrPartitionEOF Broker: No more messages</span>

1062

<span id="ErrPartitionEOF">ErrPartitionEOF</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__PARTITION_EOF">RD_KAFKA_RESP_ERR__PARTITION_EOF</a>)

1063

<span class="comment">// ErrUnknownPartition Local: Unknown partition</span>

1064

<span id="ErrUnknownPartition">ErrUnknownPartition</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION">RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION</a>)

1065

<span class="comment">// ErrFs Local: File or filesystem error</span>

1066

<span id="ErrFs">ErrFs</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__FS">RD_KAFKA_RESP_ERR__FS</a>)

1067

<span class="comment">// ErrUnknownTopic Local: Unknown topic</span>

1068

<span id="ErrUnknownTopic">ErrUnknownTopic</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC">RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC</a>)

1069

<span class="comment">// ErrAllBrokersDown Local: All broker connections are down</span>

1070

<span id="ErrAllBrokersDown">ErrAllBrokersDown</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN">RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN</a>)

1071

<span class="comment">// ErrInvalidArg Local: Invalid argument or configuration</span>

1072

<span id="ErrInvalidArg">ErrInvalidArg</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__INVALID_ARG">RD_KAFKA_RESP_ERR__INVALID_ARG</a>)

1073

<span class="comment">// ErrTimedOut Local: Timed out</span>

1074

<span id="ErrTimedOut">ErrTimedOut</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__TIMED_OUT">RD_KAFKA_RESP_ERR__TIMED_OUT</a>)

1075

<span class="comment">// ErrQueueFull Local: Queue full</span>

1076

<span id="ErrQueueFull">ErrQueueFull</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__QUEUE_FULL">RD_KAFKA_RESP_ERR__QUEUE_FULL</a>)

1077

<span class="comment">// ErrIsrInsuff Local: ISR count insufficient</span>

1078

<span id="ErrIsrInsuff">ErrIsrInsuff</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__ISR_INSUFF">RD_KAFKA_RESP_ERR__ISR_INSUFF</a>)

1079

<span class="comment">// ErrNodeUpdate Local: Broker node update</span>

1080

<span id="ErrNodeUpdate">ErrNodeUpdate</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__NODE_UPDATE">RD_KAFKA_RESP_ERR__NODE_UPDATE</a>)

1081

<span class="comment">// ErrSsl Local: SSL error</span>

1082

<span id="ErrSsl">ErrSsl</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__SSL">RD_KAFKA_RESP_ERR__SSL</a>)

1083

<span class="comment">// ErrWaitCoord Local: Waiting for coordinator</span>

1084

<span id="ErrWaitCoord">ErrWaitCoord</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__WAIT_COORD">RD_KAFKA_RESP_ERR__WAIT_COORD</a>)

1085

<span class="comment">// ErrUnknownGroup Local: Unknown group</span>

1086

<span id="ErrUnknownGroup">ErrUnknownGroup</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__UNKNOWN_GROUP">RD_KAFKA_RESP_ERR__UNKNOWN_GROUP</a>)

1087

<span class="comment">// ErrInProgress Local: Operation in progress</span>

1088

<span id="ErrInProgress">ErrInProgress</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__IN_PROGRESS">RD_KAFKA_RESP_ERR__IN_PROGRESS</a>)

1089

<span class="comment">// ErrPrevInProgress Local: Previous operation in progress</span>

1090

<span id="ErrPrevInProgress">ErrPrevInProgress</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS">RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS</a>)

1091

<span class="comment">// ErrExistingSubscription Local: Existing subscription</span>

1092

<span id="ErrExistingSubscription">ErrExistingSubscription</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION">RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION</a>)

1093

<span class="comment">// ErrAssignPartitions Local: Assign partitions</span>

1094

<span id="ErrAssignPartitions">ErrAssignPartitions</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS">RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS</a>)

1095

<span class="comment">// ErrRevokePartitions Local: Revoke partitions</span>

1096

<span id="ErrRevokePartitions">ErrRevokePartitions</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS">RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS</a>)

1097

<span class="comment">// ErrConflict Local: Conflicting use</span>

1098

<span id="ErrConflict">ErrConflict</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__CONFLICT">RD_KAFKA_RESP_ERR__CONFLICT</a>)

1099

<span class="comment">// ErrState Local: Erroneous state</span>

1100

<span id="ErrState">ErrState</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__STATE">RD_KAFKA_RESP_ERR__STATE</a>)

1101

<span class="comment">// ErrUnknownProtocol Local: Unknown protocol</span>

1102

<span id="ErrUnknownProtocol">ErrUnknownProtocol</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL">RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL</a>)

1103

<span class="comment">// ErrNotImplemented Local: Not implemented</span>

1104

<span id="ErrNotImplemented">ErrNotImplemented</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED">RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED</a>)

1105

<span class="comment">// ErrAuthentication Local: Authentication failure</span>

1106

<span id="ErrAuthentication">ErrAuthentication</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__AUTHENTICATION">RD_KAFKA_RESP_ERR__AUTHENTICATION</a>)

1107

<span class="comment">// ErrNoOffset Local: No offset stored</span>

1108

<span id="ErrNoOffset">ErrNoOffset</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__NO_OFFSET">RD_KAFKA_RESP_ERR__NO_OFFSET</a>)

1109

<span class="comment">// ErrOutdated Local: Outdated</span>

1110

<span id="ErrOutdated">ErrOutdated</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__OUTDATED">RD_KAFKA_RESP_ERR__OUTDATED</a>)

1111

<span class="comment">// ErrTimedOutQueue Local: Timed out in queue</span>

1112

<span id="ErrTimedOutQueue">ErrTimedOutQueue</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR__TIMED_OUT_QUEUE">RD_KAFKA_RESP_ERR__TIMED_OUT_QUEUE</a>)

1113

<span class="comment">// ErrUnknown Unknown broker error</span>

1114

<span id="ErrUnknown">ErrUnknown</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_UNKNOWN">RD_KAFKA_RESP_ERR_UNKNOWN</a>)

1115

<span class="comment">// ErrNoError Success</span>

1116

<span id="ErrNoError">ErrNoError</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_NO_ERROR">RD_KAFKA_RESP_ERR_NO_ERROR</a>)

1117

<span class="comment">// ErrOffsetOutOfRange Broker: Offset out of range</span>

1118

<span id="ErrOffsetOutOfRange">ErrOffsetOutOfRange</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE">RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE</a>)

1119

<span class="comment">// ErrInvalidMsg Broker: Invalid message</span>

1120

<span id="ErrInvalidMsg">ErrInvalidMsg</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_INVALID_MSG">RD_KAFKA_RESP_ERR_INVALID_MSG</a>)

1121

<span class="comment">// ErrUnknownTopicOrPart Broker: Unknown topic or partition</span>

1122

<span id="ErrUnknownTopicOrPart">ErrUnknownTopicOrPart</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART">RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART</a>)

1123

<span class="comment">// ErrInvalidMsgSize Broker: Invalid message size</span>

1124

<span id="ErrInvalidMsgSize">ErrInvalidMsgSize</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE">RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE</a>)

1125

<span class="comment">// ErrLeaderNotAvailable Broker: Leader not available</span>

1126

<span id="ErrLeaderNotAvailable">ErrLeaderNotAvailable</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE">RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE</a>)

1127

<span class="comment">// ErrNotLeaderForPartition Broker: Not leader for partition</span>

1128

<span id="ErrNotLeaderForPartition">ErrNotLeaderForPartition</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION">RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION</a>)

1129

<span class="comment">// ErrRequestTimedOut Broker: Request timed out</span>

1130

<span id="ErrRequestTimedOut">ErrRequestTimedOut</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT">RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT</a>)

1131

<span class="comment">// ErrBrokerNotAvailable Broker: Broker not available</span>

1132

<span id="ErrBrokerNotAvailable">ErrBrokerNotAvailable</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE">RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE</a>)

1133

<span class="comment">// ErrReplicaNotAvailable Broker: Replica not available</span>

1134

<span id="ErrReplicaNotAvailable">ErrReplicaNotAvailable</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE">RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE</a>)

1135

<span class="comment">// ErrMsgSizeTooLarge Broker: Message size too large</span>

1136

<span id="ErrMsgSizeTooLarge">ErrMsgSizeTooLarge</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE">RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE</a>)

1137

<span class="comment">// ErrStaleCtrlEpoch Broker: StaleControllerEpochCode</span>

1138

<span id="ErrStaleCtrlEpoch">ErrStaleCtrlEpoch</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH">RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH</a>)

1139

<span class="comment">// ErrOffsetMetadataTooLarge Broker: Offset metadata string too large</span>

1140

<span id="ErrOffsetMetadataTooLarge">ErrOffsetMetadataTooLarge</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE">RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE</a>)

1141

<span class="comment">// ErrNetworkException Broker: Broker disconnected before response received</span>

1142

<span id="ErrNetworkException">ErrNetworkException</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION">RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION</a>)

1143

<span class="comment">// ErrGroupLoadInProgress Broker: Group coordinator load in progress</span>

1144

<span id="ErrGroupLoadInProgress">ErrGroupLoadInProgress</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESS">RD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESS</a>)

1145

<span class="comment">// ErrGroupCoordinatorNotAvailable Broker: Group coordinator not available</span>

1146

<span id="ErrGroupCoordinatorNotAvailable">ErrGroupCoordinatorNotAvailable</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLE">RD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLE</a>)

1147

<span class="comment">// ErrNotCoordinatorForGroup Broker: Not coordinator for group</span>

1148

<span id="ErrNotCoordinatorForGroup">ErrNotCoordinatorForGroup</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUP">RD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUP</a>)

1149

<span class="comment">// ErrTopicException Broker: Invalid topic</span>

1150

<span id="ErrTopicException">ErrTopicException</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION">RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION</a>)

1151

<span class="comment">// ErrRecordListTooLarge Broker: Message batch larger than configured server segment size</span>

1152

<span id="ErrRecordListTooLarge">ErrRecordListTooLarge</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE">RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE</a>)

1153

<span class="comment">// ErrNotEnoughReplicas Broker: Not enough in-sync replicas</span>

1154

<span id="ErrNotEnoughReplicas">ErrNotEnoughReplicas</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS">RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS</a>)

1155

<span class="comment">// ErrNotEnoughReplicasAfterAppend Broker: Message(s) written to insufficient number of in-sync replicas</span>

1156

<span id="ErrNotEnoughReplicasAfterAppend">ErrNotEnoughReplicasAfterAppend</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND">RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND</a>)

1157

<span class="comment">// ErrInvalidRequiredAcks Broker: Invalid required acks value</span>

1158

<span id="ErrInvalidRequiredAcks">ErrInvalidRequiredAcks</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS">RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS</a>)

1159

<span class="comment">// ErrIllegalGeneration Broker: Specified group generation id is not valid</span>

1160

<span id="ErrIllegalGeneration">ErrIllegalGeneration</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION">RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION</a>)

1161

<span class="comment">// ErrInconsistentGroupProtocol Broker: Inconsistent group protocol</span>

1162

<span id="ErrInconsistentGroupProtocol">ErrInconsistentGroupProtocol</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL">RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL</a>)

1163

<span class="comment">// ErrInvalidGroupID Broker: Invalid group.id</span>

1164

<span id="ErrInvalidGroupID">ErrInvalidGroupID</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_INVALID_GROUP_ID">RD_KAFKA_RESP_ERR_INVALID_GROUP_ID</a>)

1165

<span class="comment">// ErrUnknownMemberID Broker: Unknown member</span>

1166

<span id="ErrUnknownMemberID">ErrUnknownMemberID</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID">RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID</a>)

1167

<span class="comment">// ErrInvalidSessionTimeout Broker: Invalid session timeout</span>

1168

<span id="ErrInvalidSessionTimeout">ErrInvalidSessionTimeout</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT">RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT</a>)

1169

<span class="comment">// ErrRebalanceInProgress Broker: Group rebalance in progress</span>

1170

<span id="ErrRebalanceInProgress">ErrRebalanceInProgress</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS">RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS</a>)

1171

<span class="comment">// ErrInvalidCommitOffsetSize Broker: Commit offset data size is not valid</span>

1172

<span id="ErrInvalidCommitOffsetSize">ErrInvalidCommitOffsetSize</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE">RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE</a>)

1173

<span class="comment">// ErrTopicAuthorizationFailed Broker: Topic authorization failed</span>

1174

<span id="ErrTopicAuthorizationFailed">ErrTopicAuthorizationFailed</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED">RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED</a>)

1175

<span class="comment">// ErrGroupAuthorizationFailed Broker: Group authorization failed</span>

1176

<span id="ErrGroupAuthorizationFailed">ErrGroupAuthorizationFailed</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED">RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED</a>)

1177

<span class="comment">// ErrClusterAuthorizationFailed Broker: Cluster authorization failed</span>

1178

<span id="ErrClusterAuthorizationFailed">ErrClusterAuthorizationFailed</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED">RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED</a>)

1179

<span class="comment">// ErrInvalidTimestamp Broker: Invalid timestamp</span>

1180

<span id="ErrInvalidTimestamp">ErrInvalidTimestamp</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP">RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP</a>)

1181

<span class="comment">// ErrUnsupportedSaslMechanism Broker: Unsupported SASL mechanism</span>

1182

<span id="ErrUnsupportedSaslMechanism">ErrUnsupportedSaslMechanism</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM">RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM</a>)

1183

<span class="comment">// ErrIllegalSaslState Broker: Request not valid in current SASL state</span>

1184

<span id="ErrIllegalSaslState">ErrIllegalSaslState</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE">RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE</a>)

1185

<span class="comment">// ErrUnsupportedVersion Broker: API version not supported</span>

1186

<span id="ErrUnsupportedVersion">ErrUnsupportedVersion</span> <a href="#ErrorCode">ErrorCode</a> = <a href="#ErrorCode">ErrorCode</a>(<a href="http://golang.org/pkg/C/">C</a>.<a href="http://golang.org/pkg/C/#RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION">RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION</a>)

)</pre>

func (ErrorCode)

String

</a>

</h3>

<pre>func (c <a href="#ErrorCode">ErrorCode</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

1195

<p>

1196

String returns a human readable representation of an error code

</p>

type

Event

</a>

</h2>

<pre>type Event interface {

1205

<span class="comment">// String returns a human-readable representation of the event</span>

1206

String() <a href="http://golang.org/pkg/builtin/#string">string</a>

1207

}</pre>

1208

<p>

1209

Event generic interface

</p>

type

Handle

</a>

</h2>

<pre>type Handle interface {

1218

<span class="comment">// contains filtered or unexported methods</span>

1219

}</pre>

1220

<p>

1221

Handle represents a generic client handle containing common parts for

1222

both Producer and Consumer.

</p>

type

Message

</a>

</h2>

<pre>type Message struct {

1231

TopicPartition <a href="#TopicPartition">TopicPartition</a>

1232

Value []<a href="http://golang.org/pkg/builtin/#byte">byte</a>

1233

Key []<a href="http://golang.org/pkg/builtin/#byte">byte</a>

1234

Timestamp <a href="http://golang.org/pkg/time/">time</a>.<a href="http://golang.org/pkg/time/#Time">Time</a>

1235

TimestampType <a href="#TimestampType">TimestampType</a>

Opaque interface{}

}</pre>

<p>

Message represents a Kafka message

</p>

func (*Message)

String

</a>

</h3>

<pre>func (m *<a href="#Message">Message</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

1248

<p>

1249

String returns a human readable representation of a Message.

1250

Key and payload are not represented.

</p>

type

Metadata

</a>

</h2>

<pre>type Metadata struct {

1259

Brokers []<a href="#BrokerMetadata">BrokerMetadata</a>

1260

Topics map[<a href="http://golang.org/pkg/builtin/#string">string</a>]<a href="#TopicMetadata">TopicMetadata</a>

1261

1262

OriginatingBroker <a href="#BrokerMetadata">BrokerMetadata</a>

1263

}</pre>

1264

<p>

1265

Metadata contains broker and topic metadata for all (matching) topics

</p>

type

Offset

</a>

</h2>

<pre>type Offset <a href="http://golang.org/pkg/builtin/#int64">int64</a></pre>

1274

<p>

1275

Offset type (int64) with support for canonical names

</p>

func

NewOffset

</a>

</h3>

<pre>func NewOffset(offset interface{}) (<a href="#Offset">Offset</a>, <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

1284

<p>

1285

NewOffset creates a new Offset using the provided logical string, or an

1286

absolute int64 offset value.

1287

Logical offsets: "beginning", "earliest", "end", "latest", "unset", "invalid", "stored"

</p>

func

OffsetTail

</a>

</h3>

<pre>func OffsetTail(relativeOffset <a href="#Offset">Offset</a>) <a href="#Offset">Offset</a></pre>

1296

<p>

1297

OffsetTail returns the logical offset relativeOffset from current end of partition

</p>

func (Offset)

Set

</a>

</h3>

<pre>func (o <a href="#Offset">Offset</a>) Set(offset interface{}) <a href="http://golang.org/pkg/builtin/#error">error</a></pre>

1306

<p>

1307

Set offset value, see NewOffset()

</p>

func (Offset)

String

</a>

</h3>

<pre>func (o <a href="#Offset">Offset</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

type

OffsetsCommitted

</a>

</h2>

<pre>type OffsetsCommitted struct {

1323

Error <a href="http://golang.org/pkg/builtin/#error">error</a>

1324

Offsets []<a href="#TopicPartition">TopicPartition</a>

1325

}</pre>

1326

<p>

1327

OffsetsCommitted reports committed offsets

1328

</p>

1329

1330

func (OffsetsCommitted)

String

</a>

</h3>

<pre>func (o <a href="#OffsetsCommitted">OffsetsCommitted</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

type

PartitionEOF

</a>

</h2>

<pre>type PartitionEOF <a href="#TopicPartition">TopicPartition</a></pre>

1343

<p>

1344

PartitionEOF consumer reached end of partition

</p>

func (PartitionEOF)

String

</a>

</h3>

<pre>func (p <a href="#PartitionEOF">PartitionEOF</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

type

PartitionMetadata

</a>

</h2>

<pre>type PartitionMetadata struct {

1360

ID <a href="http://golang.org/pkg/builtin/#int32">int32</a>

1361

Error <a href="#Error">Error</a>

1362

Leader <a href="http://golang.org/pkg/builtin/#int32">int32</a>

1363

Replicas []<a href="http://golang.org/pkg/builtin/#int32">int32</a>

1364

Isrs []<a href="http://golang.org/pkg/builtin/#int32">int32</a>

1365

}</pre>

1366

<p>

1367

PartitionMetadata contains per-partition metadata

</p>

type

Producer

</a>

</h2>

<pre>type Producer struct {

1376

<span class="comment">// contains filtered or unexported fields</span>

1377

}</pre>

1378

<p>

1379

Producer implements a High-level Apache Kafka Producer instance

</p>

func

NewProducer

</a>

</h3>

<pre>func NewProducer(conf *<a href="#ConfigMap">ConfigMap</a>) (*<a href="#Producer">Producer</a>, <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

1388

<p>

1389

NewProducer creates a new high-level Producer instance.

1390

</p>

1391

<p>

1392

conf is a *ConfigMap with standard librdkafka configuration properties, see here:

1393

</p>

1394

<p>

1395

Supported special configuration properties:

1396

</p>

1397

<pre>go.batch.producer (bool, false) - Enable batch producer (experimental for increased performance).

1398

These batches do not relate to Kafka message batches in any way.

1399

go.delivery.reports (bool, true) - Forward per-message delivery reports to the

1400

Events() channel.

1401

go.produce.channel.size (int, 1000000) - ProduceChannel() buffer size (in number of messages)

</pre>

func (*Producer)

Close

</a>

</h3>

<pre>func (p *<a href="#Producer">Producer</a>) Close()</pre>

1410

<p>

1411

Close a Producer instance.

1412

The Producer object or its channels are no longer usable after this call.

</p>

func (*Producer)

Events

</a>

</h3>

<pre>func (p *<a href="#Producer">Producer</a>) Events() chan <a href="#Event">Event</a></pre>

1421

<p>

1422

Events returns the Events channel (read)

</p>

func (*Producer)

Flush

</a>

</h3>

<pre>func (p *<a href="#Producer">Producer</a>) Flush(timeoutMs <a href="http://golang.org/pkg/builtin/#int">int</a>) <a href="http://golang.org/pkg/builtin/#int">int</a></pre>

1431

<p>

1432

Flush and wait for outstanding messages and requests to complete delivery.

1433

Includes messages on ProduceChannel.

1434

Runs until value reaches zero or on timeoutMs.

1435

Returns the number of outstanding events still un-flushed.

</p>

func (*Producer)

GetMetadata

</a>

</h3>

<pre>func (p *<a href="#Producer">Producer</a>) GetMetadata(topic *<a href="http://golang.org/pkg/builtin/#string">string</a>, allTopics <a href="http://golang.org/pkg/builtin/#bool">bool</a>, timeoutMs <a href="http://golang.org/pkg/builtin/#int">int</a>) (*<a href="#Metadata">Metadata</a>, <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

1444

<p>

1445

GetMetadata queries broker for cluster and topic metadata.

1446

If topic is non-nil only information about that topic is returned, else if

1447

allTopics is false only information about locally used topics is returned,

1448

else information about all topics is returned.

</p>

func (*Producer)

Len

</a>

</h3>

<pre>func (p *<a href="#Producer">Producer</a>) Len() <a href="http://golang.org/pkg/builtin/#int">int</a></pre>

1457

<p>

1458

Len returns the number of messages and requests waiting to be transmitted to the broker

1459

as well as delivery reports queued for the application.

1460

Includes messages on ProduceChannel.

</p>

func (*Producer)

Produce

</a>

</h3>

<pre>func (p *<a href="#Producer">Producer</a>) Produce(msg *<a href="#Message">Message</a>, deliveryChan chan <a href="#Event">Event</a>) <a href="http://golang.org/pkg/builtin/#error">error</a></pre>

1469

<p>

1470

Produce single message.

1471

This is an asynchronous call that enqueues the message on the internal

1472

transmit queue, thus returning immediately.

1473

The delivery report will be sent on the provided deliveryChan if specified,

1474

or on the Producer object's Events() channel if not.

1475

Returns an error if message could not be enqueued.

</p>

func (*Producer)

ProduceChannel

</a>

</h3>

<pre>func (p *<a href="#Producer">Producer</a>) ProduceChannel() chan *<a href="#Message">Message</a></pre>

1484

<p>

1485

ProduceChannel returns the produce *Message channel (write)

</p>

func (*Producer)

QueryWatermarkOffsets

1491

</a>

1492

</h3>

1493

<pre>func (p *<a href="#Producer">Producer</a>) QueryWatermarkOffsets(topic <a href="http://golang.org/pkg/builtin/#string">string</a>, partition <a href="http://golang.org/pkg/builtin/#int32">int32</a>, timeoutMs <a href="http://golang.org/pkg/builtin/#int">int</a>) (low, high <a href="http://golang.org/pkg/builtin/#int64">int64</a>, err <a href="http://golang.org/pkg/builtin/#error">error</a>)</pre>

1494

<p>

1495

QueryWatermarkOffsets returns the broker's low and high offsets for the given topic

and partition.

</p>

func (*Producer)

String

</a>

</h3>

<pre>func (p *<a href="#Producer">Producer</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

1505

<p>

1506

String returns a human readable name for a Producer instance

</p>

type

RebalanceCb

</a>

</h2>

<pre>type RebalanceCb func(*<a href="#Consumer">Consumer</a>, <a href="#Event">Event</a>) <a href="http://golang.org/pkg/builtin/#error">error</a></pre>

1515

<p>

1516

RebalanceCb provides a per-Subscribe*() rebalance event callback.

1517

The passed Event will be either AssignedPartitions or RevokedPartitions

</p>

type

RevokedPartitions

</a>

</h2>

<pre>type RevokedPartitions struct {

1526

Partitions []<a href="#TopicPartition">TopicPartition</a>

1527

}</pre>

1528

<p>

1529

RevokedPartitions consumer group rebalance event: revoked partition set

1530

</p>

1531

1532

func (RevokedPartitions)

String

</a>

</h3>

<pre>func (e <a href="#RevokedPartitions">RevokedPartitions</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

type

TimestampType

</a>

</h2>

<pre>type TimestampType <a href="http://golang.org/pkg/builtin/#int">int</a></pre>

1545

<p>

1546

TimestampType is a the Message timestamp type or source

</p>

func (TimestampType)

String

</a>

</h3>

<pre>func (t <a href="#TimestampType">TimestampType</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

type

TopicMetadata

</a>

</h2>

<pre>type TopicMetadata struct {

1562

Topic <a href="http://golang.org/pkg/builtin/#string">string</a>

1563

Partitions []<a href="#PartitionMetadata">PartitionMetadata</a>

1564

Error <a href="#Error">Error</a>

1565

}</pre>

1566

<p>

1567

TopicMetadata contains per-topic metadata

</p>

type

TopicPartition

</a>

</h2>

<pre>type TopicPartition struct {

1576

Topic *<a href="http://golang.org/pkg/builtin/#string">string</a>

1577

Partition <a href="http://golang.org/pkg/builtin/#int32">int32</a>

1578

Offset <a href="#Offset">Offset</a>

1579

Error <a href="http://golang.org/pkg/builtin/#error">error</a>

1580

}</pre>

1581

<p>

1582

TopicPartition is a generic placeholder for a Topic+Partition and optionally Offset.

1583

</p>

1584

1585

func (TopicPartition)

String

</a>

</h3>

<pre>func (p <a href="#TopicPartition">TopicPartition</a>) String() <a href="http://golang.org/pkg/builtin/#string">string</a></pre>

Build version go1.6.

<br>

Except as

noted

</a>

,

the content of this page is licensed under the

1600

Creative Commons Attribution 3.0 License,

1601

and code is licensed under a

BSD license

</a>

.

<br>

Terms of Service

</a>

|

Privacy Policy

</a>

</br>

</br>

</div>

</div>

</div>

</script>

</script>

</script>

</script>

</body>

</html>