zarinfam

@Autowired
private MockMvc mockMvc;

@Test
public void noParamGreetingShouldReturnDefaultMessage() throws Exception {

    this.mockMvc.perform(get("/greeting")).andDo(print()).andExpect(status().isOk())
            .andExpect(jsonPath("$.content").value("Hello, World!"));
}

zarinfam

$ docker run --name kafka-server2 --network kafka-net -e ALLOW_PLAINTEXT_LISTENER=yes -e KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper-server:2181 -e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9093 -p 9093:9092 bitnami/kafka:latest -d

zarinfam

$ docker run --name kafka-server1 --network kafka-net -e ALLOW_PLAINTEXT_LISTENER=yes -e KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper-server:2181 -e KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092 -p 9092:9092 bitnami/kafka:latest -d

zarinfam

$ telnet localhost 2181
Trying ::1…
Connected to localhost.
Escape character is ‘^]’.
srvr

zarinfam

$ docker run --name zookeeper-server -p 2181:2181 --network kafka-net -e ALLOW_ANONYMOUS_LOGIN=yes bitnami/zookeeper:latest -d 

zarinfam

$ docker network create kafka-net --driver bridge

zarinfam

var logger = (Serializable & LogReader) () -> readAllLogFileLines();

serializeIt(logger);

zarinfam

LogReader logReader = (Serializable & LogReader) () -> readAllLogFileLines();

if (logReader instanceof Serializable){
    System.out.println("it is Serializable");
}

serializeIt((Serializable) logReader);

zarinfam

public static <T extends LogReader & LogStreamer> void streamLog(T logSystem){
    logSystem.read().forEach(logSystem::stream);
}

zarinfam

public static void streamLog(LogReaderStreamer logReaderStreamer){
    logReaderStreamer.read().forEach(logReaderStreamer::stream);
}