baskara/kafka-consumer-grpc repository overview

⁠Kafka Consumer with gRPC

This package implements a Kafka consumer combined with gRPC (Remote Procedure Call). The main goal is to decouple the consumer from the function or service calls triggered by the events listened to by the consumer.

⁠Why This Package?

When using a consumer to listen for events to trigger a call or service, it often requires restarting the consumer service, which can be inefficient. To address this, this package provides a solution by using gRPC, allowing for a more efficient and decoupled approach.

⁠Usage

⁠Environment Variables

Before running the Kafka consumer with gRPC, set the following environment variables:

• KAFKA_BROKER: Comma-separated list of Kafka broker addresses
• GRPC_ADDRESS: Address of the gRPC server
• KAFKA_WORKER_POOL_NUMBER: Number of worker pools for concurrent message processing
• GRPC_DIAL_OPTION: Options for gRPC dialing. Use insecure for local development.
• CERT_FILE_PATH: Path to the TLS certificate file (required for production environments).