v1.27.160-final

Changelog

• cd4736e CBC.
• 1b6d970 Merge branch 'master' into more-kafka-work
• 7848836 Use Kafka broker version 3.9.0 in E2E tests (#1440)

v1.27.160-kafka

Changelog

• 32a3d67 Add E2E test for Postgres destination (#1433)
• 5e453e0 Merge branch 'master' into more-kafka-work
• 20f37a3 Merge branch 'master' into more-kafka-work
• 95259cf Merge branch 'refactor-integration-test' into more-kafka-work
• 1f8b7cc Minor code cleanliness (#1437)
• 224e559 Refactoring Integration Tests (#1439)
• 164bb0e Refactoring PartitionFrequency (#1436)
• f78c661 Renaming LatestCDCTs => LatestTimestamp + making it private (#1438)
• 65d6e15 Update.
• 5ed14f7 Update.
• 7e1723d Update.
• 5e332bc Update.
• 14b29a8 Update.

v1.27.160

Changelog

• 32a3d67 Add E2E test for Postgres destination (#1433)
• eec4650 Implement BigQuery table not found error (#1432)
• 164bb0e Refactoring PartitionFrequency (#1436)

v1.27.159-kafka-fgo

Changelog

• 32a3d67 Add E2E test for Postgres destination (#1433)
• a72ad33 Explicitly disable autocommit and set timeouts
• e532e25 Fix go.mod
• c388c11 Fix tests
• 0c31da2 Fix to process multiple messages and crash if not connected after retry
• 92660f1 Fixed commit issue with offest map and CommitOffsetsSync()
• eec4650 Implement BigQuery table not found error (#1432)
• d8c0efe Improve logging
• 3e061b8 Merge branch 'master' into kafka/franz-go
• 1121c2d Merge branch 'master' into kafka/franz-go
• d370564 Migrate segmentio/kafka-go to franz-go with Cursor
• 76e7082 Refactor to single client per consumer group
• a0d3778 Remove dialer function
• 29c8d12 Run go mod tidy
• 55f4b25 When no new messages are available, downgrade log from warn to debug

v1.27.159-kafka

Changelog

• 4b77bbe Another guardrail.
• e551321 Comment.
• ccebd1c Extra line.
• eec4650 Implement BigQuery table not found error (#1432)
• 6e20b95 Make BufferPoolSizeMin public so dashboard can use it during validation (#1426)
• f472869 Marshal SoftPartitioning struct fields to json as well (#1429)
• e190a78 Merge branch 'master' into more-kafka-work
• cf016f9 More.
• 838e1c8 New line.
• 2cd6bc9 Should Lock = True.
• 2a24aac Supporting static columns (#1425)
• 6240387 Update.
• d7e255e Update.
• 0c5ec2a Update.
• ab5eac5 Update.
• 150a7a4 Update.
• c298c15 WIP.
• 4c5e65d WIP.
• 306f5e7 WIP.
• cca09f6 [Postgres] Fix int typing (#1430)
• 4ea06a7 [Soft Partitioning] Implementation (#1427)

v1.27.159-date

Changelog

• e53d9c5 Continue
• eec4650 Implement BigQuery table not found error (#1432)
• 79490ac Skip bad date

v1.27.159

Changelog

• cca09f6 [Postgres] Fix int typing (#1430)

v1.27.158

Changelog

• f472869 Marshal SoftPartitioning struct fields to json as well (#1429)

v1.27.157

Changelog

• 4ea06a7 [Soft Partitioning] Implementation (#1427)

v1.27.156-kafka1

Changelog

• f5691b1 Skip.