- bf4d380 feat: add dataflow batch warnings and tests
- 1ac440f feat: enhance Iceberg and Nessie source connectors with polling limits and scan progress tracking
- aa839d5 feat: optimize message processing and logging in transformers and processors
- 139a0e7 feat: enhance task management and error handling in processors and connectors
- 5b88aa2 feat: add Kafka message acknowledgment warnings and enhance batch processing
- 1da8b34 fix: align source configuration formatting in dataflow batch warnings tests
- 22498eb feat: enhance KafkaSinkSpec with producer tuning options
- 6981e3f feat: add support for collapsing sink batches based on message acknowledgment
- 8ce4ee5 feat: add "when" predicate support to transformations
- 82f8008 feat: add TransformWorkers configuration and validation
- bc0da6b feat: add InsertField transformation support
- 935ad83 feat: enhance DeepCopy functionality for DebeziumUnwrapTransformation
- 69da110 feat: add ExtractField and HoistField transformation support
- 4a493a5 feat: add Cast transformation support
- a930e26 feat: add Timezone transformation support
- ce30c31 feat: enhance release notes generation with repository URL normalization
- b651b6a feat: enhance DebeziumUnwrap transformation with operation and source field options
- 899e6b4 feat: add ReplaceField transformation support
- c0d4126 feat: add HeadersToPayload transformation support
- 1cbf85b feat: enhance Filter and Router transformations with comparison predicates
- 78455ef feat: add StructFlatten transformation support
- 149315d feat: add DeepCopy methods for StructFlattenTransformation
- ecf1564 feat: add maintenance window support to DataFlow
- fce8f4b Fix: refactor DataFlowCron reconciler for improved job handling and status updates
- 4575757 feat: enhance Docker build process with caching and multi-architecture support
- 6f85f38 feat: enhance PostgreSQL CDC source with error handling
- 016ff6e feat: implement checkpoint reset handling in DataFlow reconciler
- 023d6ea feat: enhance PostgreSQL CDC checkpoint handling with new tests
- 49a6bb4 feat: enhance checkpoint reporting across connectors
- 311383c feat: implement checkpoint reset handling in DataFlowCron
- d5071a2 feat: add PostgreSQL CDC source configuration and validation
- 612add5 docs: add Agent Skills section to README with links to GitHub and documentation
- 0ee68d9 chore: update release notes generator path in .releaserc.json
1.0.45 (2026-06-14)
1.0.44 (2026-06-14)
1.0.43 (2026-06-14)
1.0.42 (2026-06-14)
1.0.41 (2026-06-11)
1.0.40 (2026-06-11)
1.0.39 (2026-06-10)
1.0.38 (2026-06-10)
1.0.37 (2026-06-08)
1.0.36 (2026-06-08)
1.0.35 (2026-06-08)
1.0.34 (2026-06-08)
1.0.33 (2026-06-08)
1.0.32 (2026-06-08)
1.0.31 (2026-06-02)
1.0.30 (2026-06-02)
1.0.29 (2026-06-02)
1.0.28 (2026-06-02)
1.0.27 (2026-06-02)
1.0.26 (2026-06-01)
1.0.25 (2026-06-01)
1.0.24 (2026-05-20)
1.0.23 (2026-05-20)
1.0.22 (2026-05-19)
1.0.21 (2026-05-19)
1.0.20 (2026-05-18)
1.0.19 (2026-05-05)
1.0.18 (2026-05-05)
1.0.17 (2026-05-05)
1.0.16 (2026-05-05)
1.0.15 (2026-05-05)
1.0.14 (2026-05-05)
1.0.13 (2026-05-04)
1.0.12 (2026-04-29)
1.0.11 (2026-04-29)
1.0.10 (2026-03-16)
- Sentry integration for error monitoring and tracing. Operator and processor pods report to Sentry when
SENTRY_DSNis set. Helm chart supportssentry.enabled,sentry.dsn,sentry.environment,sentry.tracesSampleRate,sentry.debug,sentry.release.
1.0.9 (2026-03-16)
- channelBufferSize in DataFlow spec: configurable buffer size for message channels between source, processor, and sink. Default 100; use 500–1000 for high Kafka throughput to reduce blocking when the sink is slower than the source.
1.0.8 (2026-03-16)
1.0.7 (2026-03-15)
1.0.6 (2026-03-15)
1.0.5 (2026-03-15)
1.0.4 (2026-03-15)
Удалена поддержка legacy-формата конфигурации. Source, sink и transformations теперь используют только формат type + config.
Миграция:
# Было (legacy):
source:
type: kafka
kafka:
brokers: [localhost:9092]
topic: my-topic
# Стало:
source:
type: kafka
config:
brokers: [localhost:9092]
topic: my-topicСтруктура внутри config совпадает со структурой внутри kafka/postgresql/clickhouse/trino — меняется только ключ верхнего уровня.