[KAFKA-185] Support dynamic topic naming strategies Created: 22/Jan/21 Updated: 28/Oct/23 Resolved: 08/Feb/21 |
|
| Status: | Closed |
| Project: | Kafka Connector |
| Component/s: | Source |
| Affects Version/s: | None |
| Fix Version/s: | 1.4.0 |
| Type: | Improvement | Priority: | Major - P3 |
| Reporter: | Ross Lawley | Assignee: | Ross Lawley |
| Resolution: | Fixed | Votes: | 0 |
| Labels: | None | ||
| Remaining Estimate: | Not Specified | ||
| Time Spent: | Not Specified | ||
| Original Estimate: | Not Specified | ||
| Issue Links: |
|
||||||||||||||||||||
| Epic Link: | KAFKA-47 | ||||||||||||||||||||
| Documentation Changes: | Needed | ||||||||||||||||||||
| Documentation Changes Summary: | Added Dynamic Topic Mapping for the Source Added a new interface `TopicMapper` with a `getTopic` method. Implementations can take the Change Stream Document to determine the correct `topic` to publish the data to. The Source connector includes a single implementation: `DefaultTopicMapper`. The `DefaultTopicMapper` uses the 'ns' field to determine the topic to publish to. The following configuration options can help configure topic mapping:
|
||||||||||||||||||||
| Description |
|
Similar to Only a default mapper will be added and will include prefix and suffix settings. However, it will allow users to be flexible in |
| Comments |
| Comment by Githook User [ 08/Feb/21 ] |
|
Author: {'name': 'Mario Molina', 'email': 'mmolimar@gmail.com', 'username': 'mmolimar'}Message: Added Dynamic Topic Mapping for the Source Added a new interface `TopicMapper` with a `getTopic` method. Implementations can take the The Source connector includes a single implementation: `DefaultTopicMapper`.
|