Categorygithub.com/xataio/pgstreampkgkafka
package
0.3.0
Repository: https://github.com/xataio/pgstream.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
10
Dependents
7
Files
352 SLOC

# Packages

No description provided by the author
No description provided by the author

# Functions

No description provided by the author
No description provided by the author
NewWriter returns a kafka writer that produces messages to the configured topic, using the CRC32 hash function to determine which partition to route messages to.

# Variables

No description provided by the author

# Structs

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Writer is a wrapper around the kafkago library writer.
No description provided by the author

# Interfaces

No description provided by the author
No description provided by the author
No description provided by the author

# Type aliases

Message is a wrapper around the kafkago library message.