v2.5.1

Changelog

55aea1a boundary check for integers and floats
fb0c86b bump dependent modules
3fe318a generic code to work around ClickHouse/clickhouse-go#574

v2.5.0

Changelog

• 20998a1 Use franz-go to calculate lags, close #155
• 053e61f added Bool support
• 20fa8e0 added kafka_gen_prom
• 14a5620 adjusted loglevel of batch creation
• b492fc8 bump clickhouse_go v2.2.0
• dc11462 bump roaring, clickhouse-server and go
• 53f4e1c don't escape username and password
• 5bd5fb6 introduced PromLabelsBlackList
• a6d4efd introduced WritingDurations
• bc140b5 kafka_gen_log and kafka_gen_metric use franz
• e29f04e kafka_gen_prom uses franz instead of sarama
• 4170062 make lint happy
• ccf3b5b removed non-OSS gitleaks
• 019fa9e replaced github.com/pkg/errors with github.com/thanos-io/thanos/pkg/errors, close #156
• 4257d32 replaced roaring64 with map
• f71e0fb reworked Decimal support
• d155e30 treat KEEPER_EXCEPTION as retriable
• d354aa4 use clickhouse-go/v2 write native

v2.4.2

Changelog

• 053e8ee KafkaFranz.CommitMessages retry cl.CommitRecords
• eaba9da bump thirdparty dependencies to latest releases
• 7580a1d introduced LoadSeriesAtStartup

v2.4.1

Changelog

• f15b2c2 Merge pull request #154 from twmb/master
• 4e1d9f2 bump franz-go to v1.5.0, fix kerberos breakage
• c0180eb escape labels
• c806524 improved lint.yml
• df435b7 let lint happy

v2.4.0

Changelog

• 16bcf3e add doc on how to run as a service
• b2caa69 added env local-cfg-file
• c679e67 build kafka_gen_log and kafka_gen_metric for arm64
• 3553c0f bump franz-go to v1.3.4
• 97263f4 log on Service.drain
• 4aa298a log pid at startup
• 9d34477 speedup initBmSeries

v2.3.0

Changelog

512e140 added __mgmt_id
1b81b64 added franz
b9db7a2 added franz secrity
1acefda adjusted __series_id and __mgmt_id from uint64 to int64
c53010d calculate __mgmt_id
7a23ba3 changed default kafka client from sarama to franz
9cf8e48 column name shall not be empty string
1d44572 deduplicated per __mgmt_id
064ab77 fix ErrDataLoss at startup
28cb7d6 fix tx goroutine leak
051032a fix typo
5862277 fixed Sharder.PutElems
3e7e7a9 make lint happy
e7eb2d1 minor comment
0b9b1df normallizeTask check cluster name
682347c onPartitionRevoked
c3c15f2 optimized franz config
31e334b quoted cluster, database and table in sql
2bc40bb replaced ShardingPolicy with ShardingStripe
e58aa71 revised KafkaFranz, KafkaSarama and KafkaGo Stop
a1d241f updated sonic

v2.2.0

Changelog

5ca55ad GetTaskStateAndLags
cc7406d added GetTaskStateAndLag
b5e5551 added state endpoint
7f89e31 adjusted replicaSpecificErrorCodes
c39cc30 changed default kafka version to 2.0.0
f82c1e7 create_table_query differ among 21.8.9.13, 21.10.1.8013 and 21.10.2.15
3d07fdb enabled sarama and kafka-go log
20f3a85 fixed ForceBatchOrShard became idle incorrectly
544aac3 fixed time.After leak
d4578fa more columns on kafka meta data

v2.1.0

Changelog

• added white and black list for dynamic key detection
• added TaskConfig.TimeUnit
• added gjson dynamicSchema support
• added support for UUID and Enum
• writeRows skip bad ones
• updated dependencies

v2.0.0

Changelog

• added support for prometheus style metric
• fixed Service.Stop dead lock
• respect batchSize boundary

v1.9.2

Changelog

• One clickhouse_sinker instance assign tasks to all instances in balance of message lag (by config nacos-service-name).
• Enabled sarama and kafka-go watching partition number change.