@@ -1335,7 +1335,7 @@ <h2 id="pkg-constants">
13351335 < p >
13361336 LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client
13371337 </ p >
1338- < pre > const < span id ="LibrdkafkaLinkInfo "> LibrdkafkaLinkInfo</ span > = "static glibc_linux from librdkafka-static-bundle-v1.6.1 .tgz"</ pre >
1338+ < pre > const < span id ="LibrdkafkaLinkInfo "> LibrdkafkaLinkInfo</ span > = "static glibc_linux from librdkafka-static-bundle-v1.7.0 .tgz"</ pre >
13391339 < p >
13401340 OffsetBeginning represents the earliest offset (logical)
13411341 </ p >
@@ -1404,7 +1404,7 @@ <h2 id="AdminClient">
14041404</ pre >
14051405 < h3 id ="NewAdminClient ">
14061406 func
1407- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=32689:32747#L961 ">
1407+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=32498:32556#L957 ">
14081408 NewAdminClient
14091409 </ a >
14101410 < a class ="permalink " href ="#NewAdminClient ">
@@ -1417,7 +1417,7 @@ <h3 id="NewAdminClient">
14171417 </ p >
14181418 < h3 id ="NewAdminClientFromConsumer ">
14191419 func
1420- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=34212:34284#L1010 ">
1420+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=34021:34093#L1006 ">
14211421 NewAdminClientFromConsumer
14221422 </ a >
14231423 < a class ="permalink " href ="#NewAdminClientFromConsumer ">
@@ -1431,7 +1431,7 @@ <h3 id="NewAdminClientFromConsumer">
14311431 </ p >
14321432 < h3 id ="NewAdminClientFromProducer ">
14331433 func
1434- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=33748:33820#L997 ">
1434+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=33557:33629#L993 ">
14351435 NewAdminClientFromProducer
14361436 </ a >
14371437 < a class ="permalink " href ="#NewAdminClientFromProducer ">
@@ -1445,7 +1445,7 @@ <h3 id="NewAdminClientFromProducer">
14451445 </ p >
14461446 < h3 id ="AdminClient.AlterConfigs ">
14471447 func (*AdminClient)
1448- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=25264:25426#L747 ">
1448+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=25073:25235#L743 ">
14491449 AlterConfigs
14501450 </ a >
14511451 < a class ="permalink " href ="#AdminClient.AlterConfigs ">
@@ -1478,7 +1478,7 @@ <h3 id="AdminClient.AlterConfigs">
14781478 </ p >
14791479 < h3 id ="AdminClient.Close ">
14801480 func (*AdminClient)
1481- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=32413:32442#L948 ">
1481+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=32222:32251#L944 ">
14821482 Close
14831483 </ a >
14841484 < a class ="permalink " href ="#AdminClient.Close ">
@@ -1534,7 +1534,7 @@ <h3 id="AdminClient.ControllerID">
15341534 </ p >
15351535 < h3 id ="AdminClient.CreatePartitions ">
15361536 func (*AdminClient)
1537- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=22044:22215#L657 ">
1537+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=21853:22024#L653 ">
15381538 CreatePartitions
15391539 </ a >
15401540 < a class ="permalink " href ="#AdminClient.CreatePartitions ">
@@ -1570,7 +1570,7 @@ <h3 id="AdminClient.CreateTopics">
15701570 </ p >
15711571 < h3 id ="AdminClient.DeleteTopics ">
15721572 func (*AdminClient)
1573- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=20271:20413#L599 ">
1573+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=20080:20222#L595 ">
15741574 DeleteTopics
15751575 </ a >
15761576 < a class ="permalink " href ="#AdminClient.DeleteTopics ">
@@ -1593,7 +1593,7 @@ <h3 id="AdminClient.DeleteTopics">
15931593 </ p >
15941594 < h3 id ="AdminClient.DescribeConfigs ">
15951595 func (*AdminClient)
1596- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=28466:28634#L845 ">
1596+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=28275:28443#L841 ">
15971597 DescribeConfigs
15981598 </ a >
15991599 < a class ="permalink " href ="#AdminClient.DescribeConfigs ">
@@ -1633,7 +1633,7 @@ <h3 id="AdminClient.DescribeConfigs">
16331633 </ p >
16341634 < h3 id ="AdminClient.GetMetadata ">
16351635 func (*AdminClient)
1636- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=30647:30745#L908 ">
1636+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=30456:30554#L904 ">
16371637 GetMetadata
16381638 </ a >
16391639 < a class ="permalink " href ="#AdminClient.GetMetadata ">
@@ -1650,7 +1650,7 @@ <h3 id="AdminClient.GetMetadata">
16501650 </ p >
16511651 < h3 id ="AdminClient.SetOAuthBearerToken ">
16521652 func (*AdminClient)
1653- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=31671:31753#L932 ">
1653+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=31480:31562#L928 ">
16541654 SetOAuthBearerToken
16551655 </ a >
16561656 < a class ="permalink " href ="#AdminClient.SetOAuthBearerToken ">
@@ -1675,7 +1675,7 @@ <h3 id="AdminClient.SetOAuthBearerToken">
16751675 </ p >
16761676 < h3 id ="AdminClient.SetOAuthBearerTokenFailure ">
16771677 func (*AdminClient)
1678- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=32252:32321#L943 ">
1678+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=32061:32130#L939 ">
16791679 SetOAuthBearerTokenFailure
16801680 </ a >
16811681 < a class ="permalink " href ="#AdminClient.SetOAuthBearerTokenFailure ">
@@ -1694,7 +1694,7 @@ <h3 id="AdminClient.SetOAuthBearerTokenFailure">
16941694 </ p >
16951695 < h3 id ="AdminClient.String ">
16961696 func (*AdminClient)
1697- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=30871:30908#L913 ">
1697+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/adminapi.go?s=30680:30717#L909 ">
16981698 String
16991699 </ a >
17001700 < a class ="permalink " href ="#AdminClient.String ">
@@ -1913,7 +1913,7 @@ <h3 id="AlterOperation.String">
19131913 </ p >
19141914 < h2 id ="AssignedPartitions ">
19151915 type
1916- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2636:2699#L92 ">
1916+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2554:2617#L91 ">
19171917 AssignedPartitions
19181918 </ a >
19191919 < a class ="permalink " href ="#AssignedPartitions ">
@@ -1929,7 +1929,7 @@ <h2 id="AssignedPartitions">
19291929</ pre >
19301930 < h3 id ="AssignedPartitions.String ">
19311931 func (AssignedPartitions)
1932- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2701:2744#L96 ">
1932+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2619:2662#L95 ">
19331933 String
19341934 </ a >
19351935 < a class ="permalink " href ="#AssignedPartitions.String ">
@@ -3092,7 +3092,7 @@ <h3 id="Error.TxnRequiresAbort">
30923092 </ p >
30933093 < h2 id ="ErrorCode ">
30943094 type
3095- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/generated_errors.go?s=288:306 #L1 ">
3095+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/generated_errors.go?s=289:307 #L1 ">
30963096 ErrorCode
30973097 </ a >
30983098 < a class ="permalink " href ="#ErrorCode ">
@@ -3425,7 +3425,7 @@ <h2 id="ErrorCode">
34253425)</ pre >
34263426 < h3 id ="ErrorCode.String ">
34273427 func (ErrorCode)
3428- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/generated_errors.go?s=375:409 #L4 ">
3428+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/generated_errors.go?s=376:410 #L4 ">
34293429 String
34303430 </ a >
34313431 < a class ="permalink " href ="#ErrorCode.String ">
@@ -3438,7 +3438,7 @@ <h3 id="ErrorCode.String">
34383438 </ p >
34393439 < h2 id ="Event ">
34403440 type
3441- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2304:2409#L75 ">
3441+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2222:2327#L74 ">
34423442 Event
34433443 </ a >
34443444 < a class ="permalink " href ="#Event ">
@@ -3651,7 +3651,7 @@ <h2 id="OAuthBearerToken">
36513651</ pre >
36523652 < h2 id ="OAuthBearerTokenRefresh ">
36533653 type
3654- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3642:3760#L129 ">
3654+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3560:3678#L128 ">
36553655 OAuthBearerTokenRefresh
36563656 </ a >
36573657 < a class ="permalink " href ="#OAuthBearerTokenRefresh ">
@@ -3668,7 +3668,7 @@ <h2 id="OAuthBearerTokenRefresh">
36683668</ pre >
36693669 < h3 id ="OAuthBearerTokenRefresh.String ">
36703670 func (OAuthBearerTokenRefresh)
3671- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3762:3810#L134 ">
3671+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3680:3728#L133 ">
36723672 String
36733673 </ a >
36743674 < a class ="permalink " href ="#OAuthBearerTokenRefresh.String ">
@@ -3742,7 +3742,7 @@ <h3 id="Offset.String">
37423742 < pre > func (o < a href ="#Offset "> Offset</ a > ) String() < a href ="//golang.org/pkg/builtin/#string "> string</ a > </ pre >
37433743 < h2 id ="OffsetsCommitted ">
37443744 type
3745- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3388:3461#L119 ">
3745+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3306:3379#L118 ">
37463746 OffsetsCommitted
37473747 </ a >
37483748 < a class ="permalink " href ="#OffsetsCommitted ">
@@ -3759,7 +3759,7 @@ <h2 id="OffsetsCommitted">
37593759</ pre >
37603760 < h3 id ="OffsetsCommitted.String ">
37613761 func (OffsetsCommitted)
3762- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3463:3504#L124 ">
3762+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3381:3422#L123 ">
37633763 String
37643764 </ a >
37653765 < a class ="permalink " href ="#OffsetsCommitted.String ">
@@ -3769,7 +3769,7 @@ <h3 id="OffsetsCommitted.String">
37693769 < pre > func (o < a href ="#OffsetsCommitted "> OffsetsCommitted</ a > ) String() < a href ="//golang.org/pkg/builtin/#string "> string</ a > </ pre >
37703770 < h2 id ="PartitionEOF ">
37713771 type
3772- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3213:3245#L112 ">
3772+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3131:3163#L111 ">
37733773 PartitionEOF
37743774 </ a >
37753775 < a class ="permalink " href ="#PartitionEOF ">
@@ -3784,7 +3784,7 @@ <h2 id="PartitionEOF">
37843784 < pre > type PartitionEOF < a href ="#TopicPartition "> TopicPartition</ a > </ pre >
37853785 < h3 id ="PartitionEOF.String ">
37863786 func (PartitionEOF)
3787- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3247:3284#L114 ">
3787+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=3165:3202#L113 ">
37883788 String
37893789 </ a >
37903790 < a class ="permalink " href ="#PartitionEOF.String ">
@@ -3856,7 +3856,7 @@ <h2 id="Producer">
38563856</ pre >
38573857 < h3 id ="NewProducer ">
38583858 func
3859- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=13872:13924#L423 ">
3859+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=14023:14075#L424 ">
38603860 NewProducer
38613861 </ a >
38623862 < a class ="permalink " href ="#NewProducer ">
@@ -3871,23 +3871,24 @@ <h3 id="NewProducer">
38713871 conf is a *ConfigMap with standard librdkafka configuration properties.
38723872 </ p >
38733873 < p >
3874- Supported special configuration properties:
3874+ Supported special configuration properties (type, default) :
38753875 </ p >
38763876 < pre > go.batch.producer (bool, false) - EXPERIMENTAL: Enable batch producer (for increased performance).
38773877 These batches do not relate to Kafka message batches in any way.
38783878 Note: timestamps and headers are not supported with this interface.
38793879go.delivery.reports (bool, true) - Forward per-message delivery reports to the
38803880 Events() channel.
3881- go.delivery.report.fields (string, all) - Comma separated list of fields to enable for delivery reports.
3882- Allowed values: all, none (or empty string), key, value
3881+ go.delivery.report.fields (string, "key,value") - Comma separated list of fields to enable for delivery reports.
3882+ Allowed values: all, none (or empty string), key, value, headers
3883+ Warning: There is a performance penalty to include headers in the delivery report.
38833884go.events.channel.size (int, 1000000) - Events().
38843885go.produce.channel.size (int, 1000000) - ProduceChannel() buffer size (in number of messages)
38853886go.logs.channel.enable (bool, false) - Forward log to Logs() channel.
38863887go.logs.channel (chan kafka.LogEvent, nil) - Forward logs to application-provided channel instead of Logs(). Requires go.logs.channel.enable=true.
38873888</ pre >
38883889 < h3 id ="Producer.AbortTransaction ">
38893890 func (*Producer)
3890- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=30574:30636 #L900 ">
3891+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=30707:30769 #L900 ">
38913892 AbortTransaction
38923893 </ a >
38933894 < a class ="permalink " href ="#Producer.AbortTransaction ">
@@ -3932,7 +3933,7 @@ <h3 id="Producer.AbortTransaction">
39323933 </ p >
39333934 < h3 id ="Producer.BeginTransaction ">
39343935 func (*Producer)
3935- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=24915:24958 #L763 ">
3936+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=25048:25091 #L763 ">
39363937 BeginTransaction
39373938 </ a >
39383939 < a class ="permalink " href ="#Producer.BeginTransaction ">
@@ -3983,7 +3984,7 @@ <h3 id="Producer.Close">
39833984 </ p >
39843985 < h3 id ="Producer.CommitTransaction ">
39853986 func (*Producer)
3986- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=29158:29221 #L864 ">
3987+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=29291:29354 #L864 ">
39873988 CommitTransaction
39883989 </ a >
39893990 < a class ="permalink " href ="#Producer.CommitTransaction ">
@@ -4062,7 +4063,7 @@ <h3 id="Producer.Flush">
40624063 </ p >
40634064 < h3 id ="Producer.GetFatalError ">
40644065 func (*Producer)
4065- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=20522:20562 #L661 ">
4066+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=20655:20695 #L661 ">
40664067 GetFatalError
40674068 </ a >
40684069 < a class ="permalink " href ="#Producer.GetFatalError ">
@@ -4075,7 +4076,7 @@ <h3 id="Producer.GetFatalError">
40754076 </ p >
40764077 < h3 id ="Producer.GetMetadata ">
40774078 func (*Producer)
4078- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=19105:19200 #L631 ">
4079+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=19238:19333 #L631 ">
40794080 GetMetadata
40804081 </ a >
40814082 < a class ="permalink " href ="#Producer.GetMetadata ">
@@ -4092,7 +4093,7 @@ <h3 id="Producer.GetMetadata">
40924093 </ p >
40934094 < h3 id ="Producer.InitTransactions ">
40944095 func (*Producer)
4095- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=23817:23879 #L733 ">
4096+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=23950:24012 #L733 ">
40964097 InitTransactions
40974098 </ a >
40984099 < a class ="permalink " href ="#Producer.InitTransactions ">
@@ -4175,7 +4176,7 @@ <h3 id="Producer.Logs">
41754176 </ p >
41764177 < h3 id ="Producer.OffsetsForTimes ">
41774178 func (*Producer)
4178- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=20260:20371 #L656 ">
4179+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=20393:20504 #L656 ">
41794180 OffsetsForTimes
41804181 </ a >
41814182 < a class ="permalink " href ="#Producer.OffsetsForTimes ">
@@ -4282,7 +4283,7 @@ <h3 id="Producer.Purge">
42824283 </ p >
42834284 < h3 id ="Producer.QueryWatermarkOffsets ">
42844285 func (*Producer)
4285- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=19363:19478 #L637 ">
4286+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=19496:19611 #L637 ">
42864287 QueryWatermarkOffsets
42874288 </ a >
42884289 < a class ="permalink " href ="#Producer.QueryWatermarkOffsets ">
@@ -4296,7 +4297,7 @@ <h3 id="Producer.QueryWatermarkOffsets">
42964297 </ p >
42974298 < h3 id ="Producer.SendOffsetsToTransaction ">
42984299 func (*Producer)
4299- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=27021:27158 #L808 ">
4300+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=27154:27291 #L808 ">
43004301 SendOffsetsToTransaction
43014302 </ a >
43024303 < a class ="permalink " href ="#Producer.SendOffsetsToTransaction ">
@@ -4351,7 +4352,7 @@ <h3 id="Producer.SendOffsetsToTransaction">
43514352 </ p >
43524353 < h3 id ="Producer.SetOAuthBearerToken ">
43534354 func (*Producer)
4354- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=21423:21502 #L681 ">
4355+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=21556:21635 #L681 ">
43554356 SetOAuthBearerToken
43564357 </ a >
43574358 < a class ="permalink " href ="#Producer.SetOAuthBearerToken ">
@@ -4376,7 +4377,7 @@ <h3 id="Producer.SetOAuthBearerToken">
43764377 </ p >
43774378 < h3 id ="Producer.SetOAuthBearerTokenFailure ">
43784379 func (*Producer)
4379- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=22001:22067 #L692 ">
4380+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=22134:22200 #L692 ">
43804381 SetOAuthBearerTokenFailure
43814382 </ a >
43824383 < a class ="permalink " href ="#Producer.SetOAuthBearerTokenFailure ">
@@ -4408,7 +4409,7 @@ <h3 id="Producer.String">
44084409 </ p >
44094410 < h3 id ="Producer.TestFatalError ">
44104411 func (*Producer)
4411- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=20713:20784 #L667 ">
4412+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/producer.go?s=20846:20917 #L667 ">
44124413 TestFatalError
44134414 </ a >
44144415 < a class ="permalink " href ="#Producer.TestFatalError ">
@@ -4476,7 +4477,7 @@ <h3 id="ResourceType.String">
44764477 </ p >
44774478 < h2 id ="RevokedPartitions ">
44784479 type
4479- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2885:2947#L101 ">
4480+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2803:2865#L100 ">
44804481 RevokedPartitions
44814482 </ a >
44824483 < a class ="permalink " href ="#RevokedPartitions ">
@@ -4492,7 +4493,7 @@ <h2 id="RevokedPartitions">
44924493</ pre >
44934494 < h3 id ="RevokedPartitions.String ">
44944495 func (RevokedPartitions)
4495- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2949:2991#L105 ">
4496+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2867:2909#L104 ">
44964497 String
44974498 </ a >
44984499 < a class ="permalink " href ="#RevokedPartitions.String ">
@@ -4502,7 +4503,7 @@ <h3 id="RevokedPartitions.String">
45024503 < pre > func (e < a href ="#RevokedPartitions "> RevokedPartitions</ a > ) String() < a href ="//golang.org/pkg/builtin/#string "> string</ a > </ pre >
45034504 < h2 id ="Stats ">
45044505 type
4505- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2462:2501#L83 ">
4506+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2380:2419#L82 ">
45064507 Stats
45074508 </ a >
45084509 < a class ="permalink " href ="#Stats ">
@@ -4518,7 +4519,7 @@ <h2 id="Stats">
45184519</ pre >
45194520 < h3 id ="Stats.String ">
45204521 func (Stats)
4521- < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2503:2533#L87 ">
4522+ < a href ="//golang.org/src/github.com/confluentinc/confluent-kafka-go/kafka/event.go?s=2421:2451#L86 ">
45224523 String
45234524 </ a >
45244525 < a class ="permalink " href ="#Stats.String ">
0 commit comments