From e2bf4ebb63bd87b4fa8bd26906d4adb89c31f662 Mon Sep 17 00:00:00 2001
From: augustine-p <121275043+augustine-p@users.noreply.github.com>
Date: Tue, 3 Jan 2023 22:16:23 +0530
Subject: [PATCH] GH-230: Disabled CSRF for Kinesis sample

Fixes https://github.com/spring-cloud/spring-cloud-stream-samples/issues/230
---
 .../java/demo/security/SecurityConfiguration.java | 15 +++++++++++++++
 .../demo/stream/OrderStreamConfiguration.java     |  2 ++
 2 files changed, 17 insertions(+)
 create mode 100644 kinesis-samples/kinesis-produce-consume/src/main/java/demo/security/SecurityConfiguration.java

diff --git a/kinesis-samples/kinesis-produce-consume/src/main/java/demo/security/SecurityConfiguration.java b/kinesis-samples/kinesis-produce-consume/src/main/java/demo/security/SecurityConfiguration.java
new file mode 100644
index 0000000..2f2bcbc
--- /dev/null
+++ b/kinesis-samples/kinesis-produce-consume/src/main/java/demo/security/SecurityConfiguration.java
@@ -0,0 +1,15 @@
+package demo.security;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.security.config.annotation.web.builders.HttpSecurity;
+import org.springframework.security.web.SecurityFilterChain;
+
+@Configuration
+public class SecurityConfiguration {
+
+	@Bean
+	public SecurityFilterChain filterChain(HttpSecurity httpSecurity) throws Exception {
+		return httpSecurity.csrf().disable().build();
+	}
+}
\ No newline at end of file
diff --git a/kinesis-samples/kinesis-produce-consume/src/main/java/demo/stream/OrderStreamConfiguration.java b/kinesis-samples/kinesis-produce-consume/src/main/java/demo/stream/OrderStreamConfiguration.java
index 78041b6..b0b5918 100644
--- a/kinesis-samples/kinesis-produce-consume/src/main/java/demo/stream/OrderStreamConfiguration.java
+++ b/kinesis-samples/kinesis-produce-consume/src/main/java/demo/stream/OrderStreamConfiguration.java
@@ -27,6 +27,7 @@ import org.springframework.cloud.stream.annotation.StreamListener;
 import org.springframework.context.annotation.Bean;
 
 import demo.repository.OrderRepository;
+import org.springframework.stereotype.Component;
 
 /**
  *
@@ -34,6 +35,7 @@ import demo.repository.OrderRepository;
  * @author Artem Bilan
  *
  */
+@Component
 public class OrderStreamConfiguration {
 
 	private final Log logger = LogFactory.getLog(getClass());