franz-go
franz-go contains a feature complete, pure Go library for interacting with Kafka from 0.8.0 through 3.7+. Producing, consuming, transacting, administrating, etc.
Top Related Projects
Kafka library in Go
Confluent's Apache Kafka Golang client
Sarama is a Go library for Apache Kafka.
Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.
Quick Overview
Franz-go is a feature-rich, high-performance Apache Kafka client library for Go. It provides a comprehensive set of tools for interacting with Kafka, including producing and consuming messages, managing topics and partitions, and handling various Kafka protocols.
Pros
- High performance and efficiency, optimized for Go
- Comprehensive feature set, covering most Kafka operations
- Excellent documentation and examples
- Active development and community support
Cons
- Steeper learning curve compared to simpler Kafka libraries
- May be overkill for basic Kafka operations
- Requires a good understanding of Kafka concepts and internals
Code Examples
- Producing a message:
import "github.com/twmb/franz-go/pkg/kgo"
client, err := kgo.NewClient(
kgo.SeedBrokers("localhost:9092"),
)
if err != nil {
panic(err)
}
defer client.Close()
record := &kgo.Record{Topic: "my-topic", Value: []byte("Hello, Kafka!")}
if err := client.ProduceSync(ctx, record).FirstErr(); err != nil {
panic(err)
}
- Consuming messages:
import "github.com/twmb/franz-go/pkg/kgo"
client, err := kgo.NewClient(
kgo.SeedBrokers("localhost:9092"),
kgo.ConsumerGroup("my-group"),
kgo.ConsumeTopics("my-topic"),
)
if err != nil {
panic(err)
}
defer client.Close()
for {
fetches := client.PollFetches(ctx)
if errs := fetches.Errors(); len(errs) > 0 {
// Handle errors
}
iter := fetches.RecordIter()
for !iter.Done() {
record := iter.Next()
fmt.Printf("Received: %s\n", string(record.Value))
}
}
- Creating a topic:
import "github.com/twmb/franz-go/pkg/kadm"
client, err := kgo.NewClient(kgo.SeedBrokers("localhost:9092"))
if err != nil {
panic(err)
}
defer client.Close()
admin := kadm.NewClient(client)
_, err = admin.CreateTopic(ctx, 1, 3, nil, "new-topic")
if err != nil {
panic(err)
}
Getting Started
To use franz-go in your Go project:
-
Install the library:
go get github.com/twmb/franz-go
-
Import the package in your code:
import "github.com/twmb/franz-go/pkg/kgo"
-
Create a new Kafka client:
client, err := kgo.NewClient( kgo.SeedBrokers("localhost:9092"), // Add other options as needed ) if err != nil { panic(err) } defer client.Close()
-
Use the client to interact with Kafka (produce, consume, etc.) as shown in the code examples above.
Competitor Comparisons
Kafka library in Go
Pros of kafka-go
- More established and widely used in production environments
- Better documentation and community support
- Simpler API design for basic Kafka operations
Cons of kafka-go
- Less feature-rich compared to franz-go
- Lower performance in some scenarios, especially for high-throughput applications
- Limited support for newer Kafka protocol features
Code Comparison
kafka-go:
reader := kafka.NewReader(kafka.ReaderConfig{
Brokers: []string{"localhost:9092"},
Topic: "example-topic",
Partition: 0,
MinBytes: 10e3, // 10KB
MaxBytes: 10e6, // 10MB
})
franz-go:
client, err := kgo.NewClient(
kgo.SeedBrokers("localhost:9092"),
kgo.ConsumerGroup("my-group"),
kgo.ConsumeTopics("example-topic"),
)
Both libraries offer straightforward ways to create Kafka consumers, but franz-go provides more configuration options and flexibility in a single client creation call. kafka-go's API is simpler and more intuitive for basic use cases, while franz-go offers more advanced features and control over Kafka interactions.
Confluent's Apache Kafka Golang client
Pros of confluent-kafka-go
- Official Confluent-supported library, ensuring compatibility with Confluent Platform
- Wraps the high-performance librdkafka C library for optimal performance
- Extensive documentation and examples provided by Confluent
Cons of confluent-kafka-go
- Requires CGO, which can complicate cross-compilation and deployment
- Less idiomatic Go code due to its C library wrapper nature
- Slower development cycle and community contributions due to corporate oversight
Code Comparison
confluent-kafka-go:
producer, err := kafka.NewProducer(&kafka.ConfigMap{"bootstrap.servers": "localhost"})
topic := "my-topic"
producer.Produce(&kafka.Message{
TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny},
Value: []byte("Hello, Kafka!"),
}, nil)
franz-go:
client, err := kgo.NewClient(kgo.SeedBrokers("localhost:9092"))
record := &kgo.Record{Topic: "my-topic", Value: []byte("Hello, Kafka!")}
client.Produce(context.Background(), record, func(*kgo.Record, error) {})
Both libraries offer similar functionality, but franz-go provides a more Go-idiomatic API and doesn't require CGO. However, confluent-kafka-go benefits from Confluent's official support and extensive documentation.
Sarama is a Go library for Apache Kafka.
Pros of Sarama
- More mature and widely adopted in production environments
- Extensive documentation and community support
- Offers both high-level and low-level APIs for flexibility
Cons of Sarama
- Slower development cycle and less frequent updates
- More complex API, which can lead to a steeper learning curve
- Lacks some modern Kafka features and optimizations
Code Comparison
Sarama consumer example:
consumer, err := sarama.NewConsumer([]string{"localhost:9092"}, nil)
partitionConsumer, err := consumer.ConsumePartition("topic", 0, sarama.OffsetNewest)
for message := range partitionConsumer.Messages() {
fmt.Printf("Message: %s\n", string(message.Value))
}
Franz-go consumer example:
client, err := kgo.NewClient(kgo.SeedBrokers("localhost:9092"))
client.ConsumePartitions("topic", 0)
for {
fetches := client.PollFetches(ctx)
for _, record := range fetches.Records() {
fmt.Printf("Message: %s\n", string(record.Value))
}
}
Both libraries provide similar functionality, but Franz-go offers a more streamlined API and better performance in many scenarios. Sarama remains a solid choice for projects requiring extensive community support and battle-tested stability, while Franz-go is ideal for those seeking modern features and optimized performance.
Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.
Pros of goka
- Provides a higher-level abstraction for building stream processing applications
- Includes built-in support for local storage and state management
- Offers a simpler API for common Kafka operations
Cons of goka
- Less flexible for advanced Kafka configurations and custom setups
- May have performance overhead due to higher-level abstractions
- Smaller community and fewer updates compared to franz-go
Code Comparison
goka example:
func (g *Processor) Consume() error {
return g.run(context.Background())
}
g := goka.DefineGroup(group,
goka.Input(topic, new(codec.String), process),
goka.Persist(new(codec.Int64)),
)
franz-go example:
r := kgo.NewReader(kgo.ReaderConfig{
Brokers: []string{"localhost:9092"},
Topic: "my-topic",
GroupID: "my-group",
})
for {
fetches := r.PollFetches(ctx)
// Process fetches
}
Both libraries provide Kafka client functionality for Go, but goka offers a higher-level API with built-in stream processing capabilities, while franz-go provides a more low-level and flexible approach to Kafka operations.
Convert designs to code with AI
Introducing Visual Copilot: A new AI model to turn Figma designs to high quality code using your components.
Try Visual CopilotREADME
franz-go - A complete Apache Kafka client written in Go
Franz-go is an all-encompassing Apache Kafka client fully written Go. This library aims to provide every Kafka feature from Apache Kafka v0.8.0 onward. It has support for transactions, regex topic consuming, the latest partitioning strategies, data loss detection, closest replica fetching, and more. If a client KIP exists, this library aims to support it.
This library attempts to provide an intuitive API while interacting with Kafka the way Kafka expects (timeouts, etc.).
Features
- Feature complete client (Kafka >= 0.8.0 through v3.4+)
- Full Exactly-Once-Semantics (EOS)
- Idempotent & transactional producers
- Simple (legacy) consumer
- Group consumers with eager (roundrobin, range, sticky) and cooperative (cooperative-sticky) balancers
- All compression types supported: gzip, snappy, lz4, zstd
- SSL/TLS provided through custom dialer options
- All SASL mechanisms supported (GSSAPI/Kerberos, PLAIN, SCRAM, and OAUTHBEARER)
- Low-level admin functionality supported through a simple
Request
function - High-level admin package with many helper types to make cluster administration easy.
- Utilizes modern & idiomatic Go (support for contexts, variadic configuration options, ...)
- Highly performant by avoiding channels and goroutines where not necessary
- Written in pure Go (no wrapper lib for a C library or other bindings)
- Ability to add detailed log messages or metrics using hooks
- Plug-in metrics support for prometheus, zap, etc.
- An admin client with many helper functions for easy admin tasks
- A schema registry client and convenience Serde type for encoding and decoding
Works with any Kafka compatible brokers:
- Redpanda: the fastest and most efficient Kafka compatible event streaming platform
- Kafka: the original Java project
- Confluent Platform
- Microsoft Event Hubs
- Event Hubs does not support producing with compression; be sure to use
kgo.ProducerBatchCompression(kgo.NoCompression)
.
- Event Hubs does not support producing with compression; be sure to use
- Amazon MSK
Install
This repo contains multiple tags to allow separate features to be developed and
released independently. The main client is in franz-go. Plugins are released
from plugin/{plugin}
. The raw-protocol package is released from pkg/kmsg
,
and the admin package is released from pkg/kadm
.
The main client is located in the package github.com/twmb/franz-go/pkg/kgo
,
while the root of the project is at github.com/twmb/franz-go
. There are
a few extra packages within the project, as well as a few sub-modules. To
use the main kgo package,
go get github.com/twmb/franz-go
To use a plugin,
go get github.com/twmb/franz-go/plugin/kzap
To use kadm,
go get github.com/twmb/franz-go/pkg/kadm
As an example, your require section in go.mod may look like this:
require (
github.com/twmb/franz-go v1.12.0
github.com/twmb/franz-go/pkg/kmsg v1.4.0
)
Getting started
Here's a basic overview of producing and consuming:
seeds := []string{"localhost:9092"}
// One client can both produce and consume!
// Consuming can either be direct (no consumer group), or through a group. Below, we use a group.
cl, err := kgo.NewClient(
kgo.SeedBrokers(seeds...),
kgo.ConsumerGroup("my-group-identifier"),
kgo.ConsumeTopics("foo"),
)
if err != nil {
panic(err)
}
defer cl.Close()
ctx := context.Background()
// 1.) Producing a message
// All record production goes through Produce, and the callback can be used
// to allow for synchronous or asynchronous production.
var wg sync.WaitGroup
wg.Add(1)
record := &kgo.Record{Topic: "foo", Value: []byte("bar")}
cl.Produce(ctx, record, func(_ *kgo.Record, err error) {
defer wg.Done()
if err != nil {
fmt.Printf("record had a produce error: %v\n", err)
}
})
wg.Wait()
// Alternatively, ProduceSync exists to synchronously produce a batch of records.
if err := cl.ProduceSync(ctx, record).FirstErr(); err != nil {
fmt.Printf("record had a produce error while synchronously producing: %v\n", err)
}
// 2.) Consuming messages from a topic
for {
fetches := cl.PollFetches(ctx)
if errs := fetches.Errors(); len(errs) > 0 {
// All errors are retried internally when fetching, but non-retriable errors are
// returned from polls so that users can notice and take action.
panic(fmt.Sprint(errs))
}
// We can iterate through a record iterator...
iter := fetches.RecordIter()
for !iter.Done() {
record := iter.Next()
fmt.Println(string(record.Value), "from an iterator!")
}
// or a callback function.
fetches.EachPartition(func(p kgo.FetchTopicPartition) {
for _, record := range p.Records {
fmt.Println(string(record.Value), "from range inside a callback!")
}
// We can even use a second callback!
p.EachRecord(func(record *kgo.Record) {
fmt.Println(string(record.Value), "from a second callback!")
})
})
}
This only shows producing and consuming in the most basic sense, and does not show the full list of options to customize how the client runs, nor does it show transactional producing / consuming. Check out the examples directory for more!
API reference documentation can be found on . Supplementary information can be found in the docs directory:
docs âââ admin requests â an overview of how to issue admin requests âââ metrics and logging â a small writeup on how to enable metrics & logging in franz-go, as well as a few thoughts on latency tracking âââ package layout â describes the packages in franz-go âââ producing and consuming â descriptions of producing & consuming & the guarantees âââ transactions â a description of transactions and the safety even in a pre-KIP-447 world
Who uses this?
In alphabetical order,
- Alpaca
- Banyan
- Benthos
- Conduit
- DeltaStream
- EasyPost
- Eoitek
- Hilton
- Mux
- Redpanda Console
- Redpanda Data
- Sharechat
- StoneCo
- ThinkingData
- Unistack (Cloud Management System)
- Unity Technologies
- Zomato
If you use this library and want on the list above, please either open a PR or comment on #142!
Version Pinning
By default, the client issues an ApiVersions request on connect to brokers and
defaults to using the maximum supported version for requests that each broker
supports. If you want to pin to an exact version, you can use the MaxVersions
option.
Kafka 0.10.0 introduced the ApiVersions request; if you are working with brokers older than that, you must use the kversions package. Use the MaxVersions option for the client if you do so.
Metrics & logging
Note there exists plug-in packages that allow you to easily add prometheus
metrics, go-metrics, zap logging, etc. to your client! See the plugin
directory for more information! These plugins are provided under dedicated
modules, e.g. github.com/twmb/franz-go/plugin/kprom@v1.0.0
.
The franz-go client takes a neutral approach to metrics by providing hooks that you can use to plug in your own metrics.
All connections, disconnections, reads, writes, and throttles can be hooked into, as well as per-batch produce & consume metrics. If there is an aspect of the library that you wish you could have insight into, please open an issue and we can discuss adding another hook.
Hooks allow you to log in the event of specific errors, or to trace latencies, count bytes, etc., all with your favorite monitoring systems.
In addition to hooks, logging can be plugged in with a general Logger
interface. A basic logger is provided if you just want to write to a given
file in a simple format. All logs have a message and then key/value pairs of
supplementary information. It is recommended to always use a logger and to use
LogLevelInfo
.
See this example for an expansive example of integrating with prometheus! Alternatively, see this example for how to use the plug-in prometheus package!
Benchmarks
This client is quite fast; it is the fastest and most cpu and memory efficient client in Go.
For 100 byte messages,
-
This client is 4x faster at producing than confluent-kafka-go, and up to 10x-20x faster (at the expense of more memory usage) at consuming.
-
This client is 2.5x faster at producing than sarama, and 1.5x faster at consuming.
-
This client is 2.4x faster at producing than segment's kafka-go, and anywhere from 2x to 6x faster at consuming.
To check benchmarks yourself, see the bench example. This example lets you produce or consume to a cluster and see the byte / record rate. The compare subdirectory shows comparison code.
Supported KIPs
Theoretically, this library supports every (non-Java-specific) client facing KIP. Any KIP that simply adds or modifies a protocol is supported by code generation.
KIP | Kafka release | Status |
---|---|---|
KIP-1 â Disallow acks > 1 | 0.8.3 | Supported & Enforced |
KIP-4 â Request protocol changes | 0.9.0 through 0.10.1 | Supported |
KIP-8 â Flush method on Producer | 0.8.3 | Supported |
KIP-12 â SASL & SSL | 0.9.0 | Supported |
KIP-13 â Throttling (on broker) | 0.9.0 | Supported |
KIP-15 â Close with a timeout | 0.9.0 | Supported (via context) |
KIP-19 â Request timeouts | 0.9.0 | Supported |
KIP-22 â Custom partitioners | 0.9.0 | Supported |
KIP-31 â Relative offsets in message sets | 0.10.0 | Supported |
KIP-32 â Timestamps in message set v1 | 0.10.0 | Supported |
KIP-35 â ApiVersion | 0.10.0 | Supported |
KIP-40 â ListGroups and DescribeGroups | 0.9.0 | Supported |
KIP-41 â max.poll.records | 0.10.0 | Supported (via PollRecords) |
KIP-42 â Producer & consumer interceptors | 0.10.0 | Partial support (hooks) |
KIP-43 â SASL PLAIN & handshake | 0.10.0 | Supported |
KIP-48 â Delegation tokens | 1.1 | Supported |
KIP-54 â Sticky partitioning | 0.11.0 | Supported |
KIP-57 â Fix lz4 | 0.10.0 | Supported |
KIP-62 â background heartbeats & improvements | 0.10.1 | Supported |
KIP-70 â On{Assigned,Revoked} | 0.10.1 | Supported |
KIP-74 â Fetch response size limits | 0.10.1 | Supported |
KIP-78 â ClusterID in Metadata | 0.10.1 | Supported |
KIP-79 â List offsets for times | 0.10.1 | Supported |
KIP-81 â Bound fetch memory usage | WIP | Supported (through a combo of options) |
KIP-82 â Record headers | 0.11.0 | Supported |
KIP-84 â SASL SCRAM | 0.10.2 | Supported |
KIP-86 â SASL Callbacks | 0.10.2 | Supported (through callback fns) |
KIP-88 â OffsetFetch for admins | 0.10.2 | Supported |
KIP-91 â Intuitive producer timeouts | 2.1 | Supported (as a matter of opinion) |
KIP-97 â Backwards compat for old brokers | 0.10.2 | Supported |
KIP-98 â EOS | 0.11.0 | Supported |
KIP-101 â OffsetForLeaderEpoch v0 | 0.11.0 | Supported |
KIP-102 â Consumer close timeouts | 0.10.2 | Supported (via context) |
KIP-107 â DeleteRecords | 0.11.0 | Supported |
KIP-108 â CreateTopic validate only field | 0.10.2 | Supported |
KIP-110 â zstd | 2.1 | Supported |
KIP-112 â Broker request protocol changes | 1.0 | Supported |
KIP-113 â LogDir requests | 1.0 | Supported |
KIP-117 â Admin client | 0.11.0 | Supported (via kmsg) |
KIP-124 â Request rate quotas | 0.11.0 | Supported |
KIP-126 â Ensure proper batch size after compression | 0.11.0 | Supported (avoided entirely) |
KIP-133 â Describe & Alter configs | 0.11.0 | Supported |
KIP-140 â ACLs | 0.11.0 | Supported |
KIP-144 â Broker reconnect backoff | 0.11.0 | Supported |
KIP-152 â More SASL; SASLAuthenticate | 1.0 | Supported |
KIP-183 â Elect preferred leaders | 2.2 | Supported |
KIP-185 â Idempotency is default | 1.0 | Supported |
KIP-192 â Cleaner idempotence semantics | 1.0 | Supported |
KIP-195 â CreatePartitions | 1.0 | Supported |
KIP-204 â DeleteRecords via admin API | 1.1 | Supported |
KIP-207 â New error in ListOffsets | 2.2 | Supported |
KIP-219 â Client-side throttling | 2.0 | Supported |
KIP-222 â Group operations via admin API | 2.0 | Supported |
KIP-226 â Describe configs v1 | 1.1 | Supported |
KIP-227 â Incremental fetch | 1.1 | Supported |
KIP-229 â DeleteGroups | 1.1 | Supported |
KIP-249 â Delegation tokens in admin API | 2.0 | Supported |
KIP-255 â SASL OAUTHBEARER | 2.0 | Supported |
KIP-266 â Fix indefinite consumer timeouts | 2.0 | Supported (via context) |
KIP-279 â OffsetForLeaderEpoch bump | 2.0 | Supported |
KIP-289 â Default group.id to null | 2.2 | Supported |
KIP-294 â TLS verification | 2.0 | Supported (via dialer) |
KIP-302 â Use multiple addrs for resolved hostnames | 2.1 | Supported (via dialer) |
KIP-320 â Fetcher: detect log truncation | 2.1 | Supported |
KIP-322 â DeleteTopics disabled error code | 2.1 | Supported |
KIP-339 â IncrementalAlterConfigs | 2.3 | Supported |
KIP-341 â Sticky group bugfix | ? | Supported |
KIP-342 â OAUTHBEARER extensions | 2.1 | Supported |
KIP-345 â Static group membership | 2.4 | Supported |
KIP-357 â List ACLs per principal via admin API | 2.1 | Supported |
KIP-360 â Safe epoch bumping for UNKNOWN_PRODUCER_ID | 2.5 | Supported |
KIP-361 â Allow disable auto topic creation | 2.3 | Supported |
KIP-368 â Periodically reauthenticate SASL | 2.2 | Supported |
KIP-369 â An always round robin produce partitioner | 2.4 | Supported |
KIP-373 â Users can create delegation tokens for others | 3.3 | Supported |
KIP-380 â Inter-broker protocol changes | 2.2 | Supported |
KIP-389 â Group max size error | 2.2 | Supported |
KIP-392 â Closest replica fetching w/ rack | 2.2 | Supported |
KIP-394 â Require member.id for initial join request | 2.2 | Supported |
KIP-396 â Commit offsets manually | 2.4 | Supported |
KIP-405 â Kafka Tiered Storage | 3.5 | Supported (protos) |
KIP-412 â Dynamic log levels w/ IncrementalAlterConfigs | 2.4 | Supported |
KIP-429 â Incremental rebalance (see KAFKA-8179) | 2.4 | Supported |
KIP-430 â Authorized ops in DescribeGroups | 2.3 | Supported |
KIP-447 â Producer scalability for EOS | 2.5 | Supported |
KIP-455 â Replica reassignment API | 2.4 | Supported |
KIP-460 â Leader election API | 2.4 | Supported |
KIP-464 â CreateTopic defaults | 2.4 | Supported |
KIP-467 â Per-record error codes when producing | 2.4 | Supported (and ignored) |
KIP-480 â Sticky partition producing | 2.4 | Supported |
KIP-482 â Tagged fields (KAFKA-8885) | 2.4 | Supported |
KIP-496 â OffsetDelete admin command | 2.4 | Supported |
KIP-497 â New AlterISR API | 2.7 | Supported |
KIP-498 â Max bound on reads | ? | Supported |
KIP-511 â Client name/version in ApiVersions request | 2.4 | Supported |
KIP-514 â Bounded Flush | 2.4 | Supported (via context) |
KIP-516 â Topic IDs | ??? | Supported as it is implemented |
KIP-518 â List groups by state | 2.6 | Supported |
KIP-519 â Configurable SSL "engine" | 2.6 | Supported (via dialer) |
KIP-525 â CreateTopics v5 returns configs | 2.4 | Supported |
KIP-526 â Reduce metadata lookups | 2.5 | Supported |
KIP-533 â Default API timeout (total time, not per request) | 2.5 | Supported (via RetryTimeout) |
KIP-546 â Client Quota APIs | 2.5 | Supported |
KIP-554 â Broker side SCRAM APIs | 2.7 | Supported |
KIP-559 â Protocol info in sync/join | 2.5 | Supported |
KIP-568 â Explicit rebalance triggering on the consumer | 2.6 | Supported |
KIP-569 â Docs & type in DescribeConfigs | 2.6 | Supported |
KIP-570 â Leader epoch in StopReplica | 2.6 | Supported |
KIP-580 â Exponential backoff | 2.6 | Supported |
KIP-584 â Versioning scheme for features | ? | Supported (nothing to do yet) |
KIP-588 â Producer recovery from txn timeout | 2.7 | Supported |
KIP-590 â Envelope (broker only) | 2.7 | Supported |
KIP-595 â New APIs for raft protocol | 2.7 | Supported |
KIP-599 â Throttling on create/delete topic/partition | 2.7 | Supported |
KIP-602 â Use all resolved addrs by default | 2.6 | Supported (via dialer) |
KIP-651 â Support PEM | 2.7 | Supported (via dialer) |
KIP-654 â Aborted txns with unflushed data is not fatal | 2.7 | Supported (default behavior) |
KIP-664 â Describe producers / etc. | 2.8 (mostly) | Supported |
KIP-679 â Strongest producer guarantee by default | 3.0 | Supported (by default always) |
KIP-699 â Batch FindCoordinators | 3.0 | Supported |
KIP-700 â DescribeCluster | 2.8 | Supported |
KIP-704 â AlterISR => AlterPartition | 3.2 | Supported |
KIP-709 â Batch OffsetFetch | 3.0 | Supported |
KIP-730 - AllocateProducerIDs | 3.0 | Supported |
KIP-734 â Support MaxTimestamp in ListOffsets | 3.0 | Supported (simple version bump) |
KIP-735 â Bump default session timeout | ? | Supported |
KIP-778 â KRaft Upgrades (protocol changes only) | 3.2 | Supported |
KIP-784 â Add ErrorCode to DescribeLogDirs response | 3.1 | Supported |
KIP-792 â Generation field in consumer group protocol | 3.4 | Supported |
KIP-794 â Better sticky partitioning | 3.3 | Supported (UniformBytesPartitioner ) |
KIP-800 â Reason in Join/Leave group | 3.1 | Supported |
KIP-814 â SkipAssignment for static group leaders | 3.1 | Supported |
KIP-827 â DescribeLogDirs.{Total,Usable}Bytes | 3.3 | Supported |
KIP-836 â DescribeQuorum voter lag info | 3.3 | Supported |
KIP-841 â AlterPartition.TopicID | 3.3 | Supported |
KIP-848 â Next gen consumer rebalance protocol | 3.7 | Unsupported (proto supported) |
KIP-866 â ZK to Raft RPC changes | 3.4 | Supported |
KIP-893 â Nullable structs in the protocol | 3.5 | Supported |
KIP-899 â Allow clients to rebootstrap | ? | Supported (UpdateSeedBrokers ) |
KIP-903 â Stale broker epoch fencing | 3.5 | Supported (proto) |
KIP-919 â Admin client talk to KRaft , Controller registration | 3.7 | Supported (proto) |
KIP-951 â Leader discovery optimizations | 3.7 | Supported |
Missing from above but included in librdkafka is:
- KIP-85, which does not seem relevant for franz-go
- KIP-92 for consumer lag metrics, which is better suited for an external system via the admin api
- KIP-223 for more metrics
- KIP-235, which is confusing but may be implement via a custom dialer and custom kerberos?
- KIP-359 to verify leader epoch when producing; this is easy to support but actually is not implemented in Kafka yet
- KIP-421 for dynamic values in configs; librdkafka mentions it does not support it, and neither does franz-go for the same reason (we do not use a config file)
- KIP-436 is about yet another metric
- KIP-517, more metrics
Top Related Projects
Kafka library in Go
Confluent's Apache Kafka Golang client
Sarama is a Go library for Apache Kafka.
Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.
Convert designs to code with AI
Introducing Visual Copilot: A new AI model to turn Figma designs to high quality code using your components.
Try Visual Copilot