PipedreamHQ / PipedreamHQ/pipedream

[Components] kafka

Open
#15,098 1 comment 0 reactions 1 assignee Claimed by @jcortes View on GitHub
triaged
Dominant language
JavaScript
Stars
11.7k
Forks
5.8k
Avg merge
3d 10h
Merged PRs (30d)
102

Description

# kafka
## URLs
- https://kafka.js.org/docs/introduction
- https://kafka.js.org/docs/getting-started
- https://kafka.js.org/docs/configuration
- https://kafka.js.org/docs/producing
- https://kafka.js.org/docs/transactions
- https://kafka.js.org/docs/consuming
- https://kafka.js.org/docs/running-kafka-in-development
- https://kafka.js.org/docs/producer-example
- https://kafka.js.org/docs/consumer-example

## Webhook Sources
### new-message-instant
#### Prompt
Emit new event when a message is published to a Kafka topic. Requires specifying the topic to listen on.

## Polling Sources
### new-topic-created
#### Prompt
Emit new event when a new Kafka topic is created on the cluster. Optionally filter by topic name pattern.

## Actions
### publish-message
#### Prompt
Send a message to a specified Kafka topic. Requires specifying the topic, message key, and value. Optional properties include headers and partition.
### create-topic
#### Prompt
Create a new Kafka topic. Requires specifying the topic name, number of partitions, and replication factor. Optionally configure cleanup policies or retention times.
### delete-topic
#### Prompt
Delete a specified Kafka topic. Requires the topic name as input.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.