krouter

module

v0.0.0-...-fcf41b5 Latest Latest Go to latest Published: Apr 3, 2022 License: MIT

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rmb938/krouter

Links

Open Source Insights

README ¶

krouter

This is a work in progress and features are not complete or documented

A kafka protocol router for federating multiple kafka clusters.

The federating features are abstracted away from the client which allows all native kafka clients to work with krouter.

Directories ¶

Path	Synopsis
apiServer
cmd
router
pkg
kafka/client
kafka/logical_broker
kafka/logical_broker/franz
kafka/logical_broker/internal_topics_pb
kafka/logical_broker/models
kafka/message/codec
kafka/message/codec/api_version/v0
kafka/message/codec/api_version/v2
kafka/message/codec/create_acls/v1
kafka/message/codec/describe_acls/v1
kafka/message/codec/describe_configs/v0
kafka/message/codec/describe_groups/v0
kafka/message/codec/fetch/v1
kafka/message/codec/fetch/v11
kafka/message/codec/fetch/v2
kafka/message/codec/fetch/v4
kafka/message/codec/find_coordinator/v0
kafka/message/codec/find_coordinator/v2
kafka/message/codec/heartbeat/v0
kafka/message/codec/heartbeat/v3
kafka/message/codec/init_producer_id/v0
kafka/message/codec/init_producer_id/v1
kafka/message/codec/join_group/v0
kafka/message/codec/join_group/v5
kafka/message/codec/leave_group/v0
kafka/message/codec/leave_group/v3
kafka/message/codec/list_offsets/v1
kafka/message/codec/list_offsets/v5
kafka/message/codec/metadata/v0
kafka/message/codec/metadata/v1
kafka/message/codec/metadata/v4
kafka/message/codec/metadata/v8
kafka/message/codec/offset_commit/v1
kafka/message/codec/offset_commit/v2
kafka/message/codec/offset_commit/v4
kafka/message/codec/offset_fetch/v1
kafka/message/codec/offset_fetch/v4
kafka/message/codec/produce/v1
kafka/message/codec/produce/v2
kafka/message/codec/produce/v3
kafka/message/codec/produce/v7
kafka/message/codec/sync_group/v0
kafka/message/codec/sync_group/v3
kafka/message/handler
kafka/message/handler/api_version/all
kafka/message/handler/api_version/v0
kafka/message/handler/api_version/v2
kafka/message/handler/create_acls/v1
kafka/message/handler/describe_acls/v1
kafka/message/handler/describe_configs/v0
kafka/message/handler/describe_groups/v0
kafka/message/handler/fetch/v1
kafka/message/handler/fetch/v11
kafka/message/handler/fetch/v2
kafka/message/handler/fetch/v4
kafka/message/handler/find_coordinator/v0
kafka/message/handler/find_coordinator/v2
kafka/message/handler/heartbeat/v0
kafka/message/handler/heartbeat/v3
kafka/message/handler/init_producer_id/v0
kafka/message/handler/init_producer_id/v1
kafka/message/handler/join_group/v0
kafka/message/handler/join_group/v5
kafka/message/handler/leave_group/v0
kafka/message/handler/leave_group/v3
kafka/message/handler/list_offsets/v1
kafka/message/handler/list_offsets/v5
kafka/message/handler/metadata/v0
kafka/message/handler/metadata/v1
kafka/message/handler/metadata/v4
kafka/message/handler/metadata/v8
kafka/message/handler/offset_commit/v1
kafka/message/handler/offset_commit/v2
kafka/message/handler/offset_commit/v4
kafka/message/handler/offset_fetch/v1
kafka/message/handler/offset_fetch/v4
kafka/message/handler/produce/v1
kafka/message/handler/produce/v2
kafka/message/handler/produce/v3
kafka/message/handler/produce/v7
kafka/message/handler/sync_group/v0
kafka/message/handler/sync_group/v3
kafka/message/impl/api_version
kafka/message/impl/api_version/v0
kafka/message/impl/api_version/v2
kafka/message/impl/create_acls
kafka/message/impl/create_acls/v1
kafka/message/impl/describe_acls
kafka/message/impl/describe_acls/v1
kafka/message/impl/describe_configs
kafka/message/impl/describe_configs/v0
kafka/message/impl/describe_groups
kafka/message/impl/describe_groups/v0
kafka/message/impl/errors
kafka/message/impl/fetch
kafka/message/impl/fetch/v1
kafka/message/impl/fetch/v11
kafka/message/impl/fetch/v2
kafka/message/impl/fetch/v4
kafka/message/impl/find_coordinator
kafka/message/impl/find_coordinator/v0
kafka/message/impl/find_coordinator/v2
kafka/message/impl/heartbeat
kafka/message/impl/heartbeat/v0
kafka/message/impl/heartbeat/v3
kafka/message/impl/init_producer_id
kafka/message/impl/init_producer_id/v0
kafka/message/impl/init_producer_id/v1
kafka/message/impl/join_group
kafka/message/impl/join_group/v0
kafka/message/impl/join_group/v5
kafka/message/impl/leave_group
kafka/message/impl/leave_group/v0
kafka/message/impl/leave_group/v3
kafka/message/impl/list_offsets
kafka/message/impl/list_offsets/v1
kafka/message/impl/list_offsets/v5
kafka/message/impl/metadata
kafka/message/impl/metadata/v0
kafka/message/impl/metadata/v1
kafka/message/impl/metadata/v4
kafka/message/impl/metadata/v8
kafka/message/impl/offset_commit
kafka/message/impl/offset_commit/v1
kafka/message/impl/offset_commit/v2
kafka/message/impl/offset_commit/v4
kafka/message/impl/offset_fetch
kafka/message/impl/offset_fetch/v1
kafka/message/impl/offset_fetch/v4
kafka/message/impl/produce
kafka/message/impl/produce/v1
kafka/message/impl/produce/v2
kafka/message/impl/produce/v3
kafka/message/impl/produce/v7
kafka/message/impl/sync_group
kafka/message/impl/sync_group/v0
kafka/message/impl/sync_group/v3
kafka/records
net/codec
net/message
net/message/handler
redisw
router

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL