diff --git a/kafka/README.md b/kafka/README.md index 5da82c482..98152e9e3 100644 --- a/kafka/README.md +++ b/kafka/README.md @@ -44,16 +44,21 @@ $ go test -coverprofile=coverage.out -bench=. $ go tool cover -func=coverage.out ``` -## Build tags (static linking) +## Build tags Different build types are supported through Go build tags (`-tags ..`), -these tags should be specified on the **application** build command. +these tags should be specified on the **application** build/get/install command. - * `static` - Build with librdkafka linked statically (but librdkafka - dependencies linked dynamically). - * `static_all` - Build with all libraries linked statically. - * neither - Build with librdkafka (and its dependencies) linked dynamically. + * By default the bundled platform-specific static build of librdkafka will + be used. This works out of the box on Mac OSX and glibc-based Linux distros, + such as Ubuntu and CentOS. + * `-tags musl` - must be specified when building on/for musl-based Linux + distros, such as Alpine. Will use the bundled static musl build of + librdkafka. + * `-tags dynamic` - link librdkafka dynamically. A shared librdkafka library + must be installed manually through other means (apt-get, yum, build from + source, etc). @@ -74,12 +79,9 @@ $ make -f mk/Makefile docs For each release candidate and final release, perform the following steps: -### Install librdkafka +### Update bundle to latest librdkafka -Make sure the librdkafka version installed is the version this release -is aimed to be used with. - -E.g., confluent-kafka-go v1.3.0 will require librdkafka v1.3.0. +See instructions in [kafka/librdkafka/README.md](kafka/librdkafka/README.md). ### Update librdkafka version requirement diff --git a/kafka/api.html b/kafka/api.html index 88dc4ec12..2518d8979 100644 --- a/kafka/api.html +++ b/kafka/api.html @@ -381,6 +381,11 @@
+ LibrdkafkaLinkInfo explains how librdkafka was linked to the Go client +
+const LibrdkafkaLinkInfo = "static glibc_linux from librdkafka-static-bundle-v1.4.0.tgz"
OffsetBeginning represents the earliest offset (logical)
@@ -1326,7 +1338,7 @@const PartitionAny = int32(C.RD_KAFKA_PARTITION_UA)
LibraryVersion returns the underlying librdkafka library version as a (version_int, version_str) tuple. +
+func WriteErrorCodes(f *os.File)+
+ WriteErrorCodes writes Go error code constants to file from the +librdkafka error codes. +This function is not intended for public use.
The returned offset for each partition is the earliest offset whose timestamp is greater than or equal to the given timestamp in the -corresponding partition. +corresponding partition. If the provided timestamp exceeds that of the +last message in the partition, a value of -1 will be returned.
The timestamps to query are represented as `.Offset` in the `times` @@ -2443,7 +2471,7 @@
Upon successful return from this function the application has to perform at -least one of the following operations within `transactional.timeout.ms` to +least one of the following operations within `transaction.timeout.ms` to avoid timing out the transaction on the broker:
* `Produce()` (et.al) @@ -4001,7 +4029,7 @@
func (*Producer) - + OffsetsForTimes @@ -4015,7 +4043,8 @@
The returned offset for each partition is the earliest offset whose timestamp is greater than or equal to the given timestamp in the -corresponding partition. +corresponding partition. If the provided timestamp exceeds that of the +last message in the partition, a value of -1 will be returned.
The timestamps to query are represented as `.Offset` in the `times` @@ -4121,7 +4150,7 @@
func (*Producer) - + SendOffsetsToTransaction @@ -4176,7 +4205,7 @@
func (*Producer) - + SetOAuthBearerToken @@ -4201,7 +4230,7 @@
func (*Producer) - + SetOAuthBearerTokenFailure @@ -4233,7 +4262,7 @@
func (*Producer) - + TestFatalError @@ -4394,7 +4423,7 @@
func (p TopicPartition) String() string
type TopicPartitions []TopicPartition
func (tps TopicPartitions) Len() int
func (tps TopicPartitions) Less(i, j int) bool