removed wrong merge code (#10825)

This commit is contained in:
Onkar Ravgan 2023-03-29 18:02:38 +05:30 committed by GitHub
parent 744cac26c4
commit c6538a38bf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -126,10 +126,6 @@ class KinesisSource(MessagingServiceSource):
), ),
maximumMessageSize=self._get_max_message_size(), 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) self.register_record(topic_request=topic)
yield topic yield topic