Implementation:Risingwavelabs Risingwave ConnectorService Main

Knowledge Sources	RisingWave
Domains	CDC, Connectors, Microservices, gRPC
Last Updated	2026-02-09 07:00 GMT

Overview

Concrete tool for launching the Java connector gRPC service provided by the RisingWave connector node.

Description

ConnectorService.main() is the entry point for the Java connector node. It parses command-line arguments, initializes Prometheus metrics, creates a gRPC server with ConnectorServiceImpl, and starts listening for RPC requests from the Rust core engine.

Usage

This is launched automatically as part of RisingWave cluster startup. It runs alongside the Rust components and communicates via gRPC and JNI.

Code Reference

Source Location

• Repository: risingwave
• File: java/connector-node/risingwave-connector-service/src/main/java/com/risingwave/connector/ConnectorService.java
• Lines: L34-65

Signature

public class ConnectorService {
    public static void main(String[] args) throws Exception {
        // Parses CLI args: -p/--port, -P/--prometheus-http-host
        // Starts gRPC server with ConnectorServiceImpl
        // Starts Prometheus metrics HTTP endpoint
    }
}

Import

import com.risingwave.connector.ConnectorService;

I/O Contract

Inputs

Name	Type	Required	Description
-p / --port	CLI argument	No	gRPC port (default: 50051, env: RW_CONNECTOR_NODE_PORT)
-P / --prometheus-http-host	CLI argument	No	Prometheus bind address (default: 0.0.0.0)
RW_CONNECTOR_NODE_PROMETHEUS_PORT	Environment variable	No	Prometheus port (default: 50052)

Outputs

Name	Type	Description
gRPC server	Network service	Listening on port 50051 for ConnectorServiceImpl RPCs
Prometheus endpoint	HTTP service	Metrics on port 50052

Usage Examples

Start Connector Service

# Start with default settings
java -cp connector-service.jar com.risingwave.connector.ConnectorService

# Start with custom port
java -cp connector-service.jar com.risingwave.connector.ConnectorService -p 50060

Related Pages

Implements Principle

• Principle:Risingwavelabs_Risingwave_CDC_Connector_Service

Requires Environment

• Environment:Risingwavelabs_Risingwave_Java_Connector_Environment