Ignore Kinesis tests when no local Kinesis

kinesis-samples/kinesis-to-webflux/src/test/java/kinesis/webflux/CloudStreamKinesisToWebfluxApplicationTests.java

@@ -16,10 +16,14 @@
 
 package kinesis.webflux;
 
+import static org.assertj.core.api.Assumptions.assumeThat;
+
+import java.net.Socket;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.function.Supplier;
 
+import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
 
 import org.springframework.beans.factory.annotation.Autowired;
@@ -67,6 +71,20 @@ public class CloudStreamKinesisToWebfluxApplicationTests {
 	@Autowired
 	private KinesisTestConfiguration kinesisTestConfiguration;
 
+	@BeforeAll
+	static void setup() {
+		boolean isLocalKinesis;
+		try {
+			new Socket("localhost", KinesisTestConfiguration.DEFAULT_KINESALITE_PORT).close();
+			// Successful connection means local Kinesis is available
+			isLocalKinesis = true;
+		}
+		catch (Exception e) {
+			isLocalKinesis  = false;
+		}
+		assumeThat(isLocalKinesis).isTrue();
+	}
+
 	@Test
 	void testKinesisToWebFlux() {
 		this.kinesisTestConfiguration.eventQueue.offer("foo");