Skip to content

Latest commit

 

History

History
35 lines (25 loc) · 1.22 KB

README.md

File metadata and controls

35 lines (25 loc) · 1.22 KB
Raw

Kroxylicious Filter for Kafka Connect API interactions

A filter based on the Kroxylicious sample filter that observes the following API interactions:

  • FindCoordinatorRequest
  • FindCoordinatorResponse
  • JoinGroupRequest
  • JoinGroupResponse
  • SyncGroupRequest
  • SyncGroupResponse
  • HeartbeatResponse (if an error code is included)

Build the Filter

Build the filter with:

mvn package

Run the Filter

To run the filter execute the following command, replacing the PATH-TO-KROXYLICIOUS with your Kroxylicious install:

KROXYLICIOUS_CLASSPATH="kroxylicious-connect-filter/target/kroxylicious-connect-filter-0.0.1-jar-with-dependencies.jar" /PATH-TO-KROXYLICIOUS/bin/kroxylicious-start.sh --config proxy-config-1.yaml

You can then start Kafka Connect with bootstrap.servers=localhost:9192.

To run a second worker, start a second Kroxylicious with:

KROXYLICIOUS_CLASSPATH="kroxylicious-connect-filter/target/kroxylicious-connect-filter-0.0.1-jar-with-dependencies.jar" /PATH-TO-KROXYLICIOUS/bin/kroxylicious-start.sh --config proxy-config-2.yaml

The second Kafka Connect worker should have bootstrap.servers=localhost:9195.