tinybird

decodableco · Aug 11, 2022 · 10b678e · 10b678e
1 parent ca2e1a0
commit 10b678e
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 10 deletions.
diff --git a/tinybird/datasources/decodable_wikipedia.datasource b/tinybird/datasources/decodable_wikipedia.datasource
@@ -23,7 +23,7 @@ ENGINE "MergeTree"
 ENGINE_PARTITION_KEY "toYYYYMM(timestamp)"
 ENGINE_SORTING_KEY "timestamp"
 
-KAFKA_CONNECTION_NAME 'pkc-4r087.us-west2.gcp.confluent.cloud:9092'
+KAFKA_CONNECTION_NAME 'xxxxxxxxxxx.confluent.cloud:9092'
 KAFKA_TOPIC 'wiki'
 KAFKA_GROUP_ID 'tinybird_wikipedia'
 KAFKA_AUTO_OFFSET_RESET 'latest'

diff --git a/tinybird/datasources/events_example.datasource b/tinybird/datasources/events_example.datasource
diff --git a/tinybird/wiki.py b/tinybird/wiki.py
@@ -13,7 +13,7 @@ def kinesis():
 	return boto3.client('kinesis',region_name=os.getenv("REGION"))
 
 def poll():
-	feed=feedparser.parse('https://en.wikipedia.org/w/api.php?action=feedrecentchanges&format=json')
+	feed=feedparser.parse('https://en.wikipedia.org/w/api.php?action=feedrecentchanges')
 	entries = feed['entries']
 	stream = os.getenv("KINESIS_STREAM")
 	k = kinesis()