replicate
replicate copied to clipboard
unmeshjoshi
There is no main method. How is this code intended to be executed? Only through unit tests? Also, the Docker file mentions Go. What is Go used for in this...
The tests are run by assigning random ports in method TestUtils.getRandomPort. It looks like the ports conflict once in a while. Kafka had similar issue https://issues.apache.org/jira/browse/KAFKA-1501 and they discourage use...
replicator/src/main/java/replicate/net/SocketClient.java blocks in blockingSendAndReceive if no read timeout is set. Ideally, the server should return error response in case request futures in the async processing pipeline do not complete.