kafka

package module

v0.0.0-...-18fd54f Latest Latest Go to latest Published: Oct 26, 2023 License: MIT Imports: 7 Imported by: 0

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/smarty/messaging-kafka

Links

Open Source Insights

README ¶

SMARTY DISCLAIMER: Subject to the terms of the associated license agreement, this software is freely available for your use. This software is FREE, AS IN PUPPIES, and is a gift. Enjoy your new responsibility. This means that while we may consider enhancement requests, we may or may not choose to entertain requests at our sole and absolute discretion.

Documentation ¶

Index ¶

Variables
func NewConnector(options ...option) messaging.Connector
type Logger
type Monitor

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	CompressionMethodNone      compressionMethod = 0
	CompressionMethodGZip      compressionMethod = 1
	CompressionMethodLz4       compressionMethod = 2
	CompressionMethodSnappy    compressionMethod = 3
	CompressionMethodZStandard compressionMethod = 4
)

View Source

var (
	PartitionSelectionRoundRobin partitionSelection = 0
	PartitionSelectionMurmurHash partitionSelection = 1
	PartitionSelectionFNVHash    partitionSelection = 2
	PartitionSelectionCrc32Hash  partitionSelection = 3
	PartitionSelectionLeastBytes partitionSelection = 4
)

View Source

var (
	RequiredWritesNone requiredWrites = 0
	RequiredWritesOne  requiredWrites = 1
	RequiredWritesAll  requiredWrites = 2
)

View Source

var Options singleton

Functions ¶

func NewConnector ¶

func NewConnector(options ...option) messaging.Connector

Types ¶

type Logger ¶

type Logger interface {
	Printf(string, ...interface{})
}

type Monitor ¶

type Monitor interface {
	ConnectionOpened(error)
	ConnectionClosed()
	DispatchPublished()
	DeliveryReceived()
	DeliveryAcknowledged(uint64, error)
	TransactionCommitted(error)
	TransactionRolledBack(error)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
main

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