coinbase-producer

Kafka producer for coinbase feeds.

Logging

Info

• subscription messages sent to coinbase.
• messages consumed from coinbase.

Warnings

• coinbase reconnection errors.

Local Testing

• make install install python dependencies.
• make test-format tests formating and performs static type checking.
• make test-unit tests live message consumption to a mock kafka stream.
• make test-integration tests helm deployment with kafka broker.

CI/CD

• pull request format, unit, and integration tests.
• merge to main docker and helm release (if version bumped).

Deployment

Message deduplication should be implemented if the producer is replicated.