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.

Sign up for GitHub

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

Jump to bottom

Kafka Connect: Add mechanisms for routing records by topic name #11623

Open
wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Kafka Connect: Add mechanisms for routing records by topic name #11623

wants to merge 1 commit into from
+652 −114

Commits on Nov 21, 2024

  1. Kafka Connect: Add mechanisms for routing records by topic name 

    Add 2 new routing mechanisms for records that use Kafka topic name for
routing and update configuration for how to route records.

The changes move the routing logic to a separate class with different
implementations that can be selected via the configuration. It preserves
backwards compatibility of current behavior, while adding 2 new ways to
route records to tables based on the Kafka topic and also allows
custom implementations of how records are routed.

The two new routing mechanisms allow the connector to consume from
multiple topics, eliminating the need to create separate connectors
for each topic to consume from.
    @mun1r0b0t
    mun1r0b0t committed Nov 21, 2024
    Configuration menu
    Copy the full SHA
    bc08dda View commit details
    Browse the repository at this point in the history