| 552 | ) |
| 553 | |
| 554 | def _to_proto_impl(self) -> DataSourceProto: |
| 555 | data_source_proto = DataSourceProto( |
| 556 | name=self.name, |
| 557 | type=DataSourceProto.STREAM_KAFKA, |
| 558 | field_mapping=self.field_mapping, |
| 559 | kafka_options=self.kafka_options.to_proto(), |
| 560 | description=self.description, |
| 561 | tags=self.tags, |
| 562 | owner=self.owner, |
| 563 | ) |
| 564 | |
| 565 | data_source_proto.timestamp_field = self.timestamp_field |
| 566 | data_source_proto.created_timestamp_column = self.created_timestamp_column |
| 567 | if self.batch_source: |
| 568 | data_source_proto.batch_source.MergeFrom(self.batch_source.to_proto()) |
| 569 | |
| 570 | return data_source_proto |
| 571 | |
| 572 | def validate(self, config: RepoConfig): |
| 573 | raise NotImplementedError |