Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Kafka Resource for Simplified Routine Load Broker Management #53113

Open
jselvareef opened this issue Nov 22, 2024 · 0 comments
Open

Kafka Resource for Simplified Routine Load Broker Management #53113

jselvareef opened this issue Nov 22, 2024 · 0 comments

Comments

@jselvareef
Copy link

Feature request

Is your feature request related to a problem? Please describe.
Currently, when creating a routine load in StarRocks to consume data from a Kafka topic, we must specify the broker_list property directly in the routine load. This creates significant overhead when managing multiple routine loads.

For instance, with 20 or more routine loads, the same broker_list must be repeated in all of them. If maintenance occurs in Kafka, such as adding or removing brokers, we must update the broker_list in each of these routine loads individually. This is inefficient and prone to error.

Describe the solution you'd like
Introduce a new type of "RESOURCE" where type=kafka. This resource would include properties like broker_list. When creating a routine load, instead of specifying the broker_list, users would reference this Kafka resource.

This approach centralizes the management of the broker_list in the Kafka resource. If updates are needed, they can be made in a single place without requiring changes to every routine load that relies on it.

Describe alternatives you've considered

  • Manually updating the broker_list in every routine load after Kafka maintenance. However, this is not scalable or practical when dealing with a large number of routine loads.

  • Writing automation scripts to update routine loads programmatically. This adds complexity and requires external tooling, which could introduce additional failure points.

Additional context
This feature would significantly improve the user experience for managing Kafka-based routine loads in environments with high routine load counts. It would also reduce the risk of misconfiguration during Kafka maintenance activities.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant