diff --git a/ingestion/src/metadata/ingestion/source/messaging/kinesis/metadata.py b/ingestion/src/metadata/ingestion/source/messaging/kinesis/metadata.py index 9a53b29eb05..0aa90fa325b 100644 --- a/ingestion/src/metadata/ingestion/source/messaging/kinesis/metadata.py +++ b/ingestion/src/metadata/ingestion/source/messaging/kinesis/metadata.py @@ -126,10 +126,6 @@ class KinesisSource(MessagingServiceSource): ), maximumMessageSize=self._get_max_message_size(), ) - if self.generate_sample_data: - topic.sampleData = self._get_sample_data( - topic_details.topic_name, topic_details.topic_metadata["partitions"] - ) self.register_record(topic_request=topic) yield topic