https://community.splunk.com/t5/Splunk-Dev/Why-can-I-not-submit-data-via-sockets-in-the-java-SDK/m-p/538192#M9659 <P>Below I have a setup which is submitting an event to splunk. I would like to not recreate a connection and stream several events at a time. What can I do to achieve this? I attempted to use a socket below, but it always errors out with `&lt;msg type="ERROR"&gt;Read Timeout&lt;/msg&gt;`.</P><LI-CODE lang="java">public class Main { static final ObjectMapper mapper = new ObjectMapper(); public static void main(String[] args) throws Exception { Map&lt;String,Object&gt; map = new HashMap&lt;&gt;(); { map.put("host", System.getenv("SPLUNKHOST")); map.put("username", System.getenv("USER")); map.put("password", System.getenv("PASSWORD")); } Service.setSslSecurityProtocol(SSLSecurityProtocol.TLSv1_2); final Service srv = Service.connect(map); working(srv); broken(srv); } static void working(Service srv) throws Exception { final Receiver receiver = srv.getReceiver(); String str = mapper.writeValueAsString(data("rec_http")); receiver.log("api_analytics", str); } static void broken(Service srv) throws Exception { final Index index = srv.getIndexes().get("api_analytics"); final Socket sock = index.attach(); String str = mapper.writeValueAsString(data("sock")); final OutputStream out = sock.getOutputStream(); final InputStream in = sock.getInputStream(); out.write(str.getBytes()); String r = new String(in.readAllBytes()); System.out.println(r); sock.close(); } static Object data(String src) { Map&lt;Object,Object&gt; map = new HashMap&lt;&gt;(); map.put("index","api_analytics"); map.put("source",src); return map; } }</LI-CODE> Mon, 01 Feb 2021 22:54:32 GMT tjones 2021-02-01T22:54:32Z https://community.splunk.com/t5/Splunk-Dev/Why-can-I-not-submit-data-via-sockets-in-the-java-SDK/m-p/538192#M9659 <P>Below I have a setup which is submitting an event to splunk. I would like to not recreate a connection and stream several events at a time. What can I do to achieve this? I attempted to use a socket below, but it always errors out with `&lt;msg type="ERROR"&gt;Read Timeout&lt;/msg&gt;`.</P><LI-CODE lang="java">public class Main { static final ObjectMapper mapper = new ObjectMapper(); public static void main(String[] args) throws Exception { Map&lt;String,Object&gt; map = new HashMap&lt;&gt;(); { map.put("host", System.getenv("SPLUNKHOST")); map.put("username", System.getenv("USER")); map.put("password", System.getenv("PASSWORD")); } Service.setSslSecurityProtocol(SSLSecurityProtocol.TLSv1_2); final Service srv = Service.connect(map); working(srv); broken(srv); } static void working(Service srv) throws Exception { final Receiver receiver = srv.getReceiver(); String str = mapper.writeValueAsString(data("rec_http")); receiver.log("api_analytics", str); } static void broken(Service srv) throws Exception { final Index index = srv.getIndexes().get("api_analytics"); final Socket sock = index.attach(); String str = mapper.writeValueAsString(data("sock")); final OutputStream out = sock.getOutputStream(); final InputStream in = sock.getInputStream(); out.write(str.getBytes()); String r = new String(in.readAllBytes()); System.out.println(r); sock.close(); } static Object data(String src) { Map&lt;Object,Object&gt; map = new HashMap&lt;&gt;(); map.put("index","api_analytics"); map.put("source",src); return map; } }</LI-CODE> Mon, 01 Feb 2021 22:54:32 GMT https://community.splunk.com/t5/Splunk-Dev/Why-can-I-not-submit-data-via-sockets-in-the-java-SDK/m-p/538192#M9659 tjones 2021-02-01T22:54:32Z