kafka

package module

v0.0.0-...-a98cc76 Latest Latest Go to latest Published: Jan 6, 2025 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/smarty/messaging-kafka

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