What do you want to automate
with Splunk HTTP Event Collector and Kafka?
Prompt, edit and deploy AI agents that connect to Splunk HTTP Event Collector, Kafka and 2,500+ other apps in seconds.
Trusted by 1,000,000+ developers from startups to Fortune 500 companies
Start for free — no credit card required
Watch a demo
Popular Splunk HTTP Event Collector and Kafka Actions#
Check Splunk HTTP Event Collector Health with the Splunk HTTP Event Collector API
Checks the health status of the Splunk HTTP Event Collector to ensure it is available and ready to receive events. See the documentation
Send Batch Events with the Splunk HTTP Event Collector API
Sends multiple events in a single request to the Splunk HTTP Event Collector. See the documentation
Send Event with the Splunk HTTP Event Collector API
Sends an event to Splunk HTTP Event Collector. See the documentation
Integrate the Splunk HTTP Event Collector API with the Kafka API
Setup the Splunk HTTP Event Collector API trigger to run a workflow which integrates with the Kafka API. Pipedream's integration platform allows you to integrate Splunk HTTP Event Collector and Kafka remarkably fast. Free for developers.
Connect Splunk HTTP Event Collector#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
import { axios } from "@pipedream/platform"
export default defineComponent({
props: {
splunk_http_event_collector: {
type: "app",
app: "splunk_http_event_collector",
}
},
async run({steps, $}) {
const data = {
"event": `Hello world!`,
"sourcetype": `manual`,
}
return await axios($, {
method: "post",
url: `${this.splunk_http_event_collector.$auth.api_url}:${this.splunk_http_event_collector.$auth.port}/services/collector`,
headers: {
"authorization": `Splunk ${this.splunk_http_event_collector.$auth.api_token}`,
},
params: {
channel: `2AC79941-CB26-421C-8826-F57AE23E9702`,
},
data,
})
},
})
Connect Kafka#
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
import { Kafka } from "kafkajs"
export default defineComponent({
props: {
kafka: {
type: "app",
app: "kafka",
}
},
async run({steps, $}) {
const kafka = new Kafka({
brokers: [`${this.kafka.$auth.host}:${this.kafka.$auth.port}`],
});
const consumer = kafka.consumer({ groupId: 'TestGroup' });
await consumer.connect()
await consumer.subscribe({ topic: 'SampleTopic', fromBeginning: true });
let consumedMessage = "";
const eachMessage = async function({ topic, partition, message }){
consumedMessage = message.value.toString();
return consumedMessage;
};
await consumer.run({
eachMessage,
});
const producer = kafka.producer();
await producer.connect()
await producer.send({
topic: 'SampleTopic',
messages: [
{ value: 'Welcome KafkaJS + Pipedream users! '+ new Date().toISOString() },
],
});
await producer.disconnect();
const data = await consumer.describeGroup();
return { consumedMessage, groupDescription: data };
},
})
Start for free — no credit card required
Watch a demo
Trusted by 1,000,000+ developers from startups to Fortune 500 companies