PipedreamHQ / PipedreamHQ/pipedream
[Components] kafka
- 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
Assessment
This issue has not been assessed yet.