Thales Macedo Garitezi
|
19f9c35662
|
docs: improve descriptions
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
|
2023-03-16 13:43:01 -03:00 |
|
Thales Macedo Garitezi
|
fc5dfa108a
|
fix(kafka_consumer): rename `force_utf8` to `none`
We actually enforce the key/value to be a valid UTF-8 string when
using `emqx_json:encode`, if we do encode using that, which is
template-dependent.
|
2023-03-16 13:43:01 -03:00 |
|
Thales Macedo Garitezi
|
53979b6261
|
feat(kafka_consumer): support multiple topic mappings, payload
templates and key/value encodings
Added after feedback from the product team.
|
2023-03-16 13:43:01 -03:00 |
|
Thales Macedo Garitezi
|
f31f15e44e
|
chore(kafka_producer): make schema changes more backwards compatible
This will still require fixes to the frontend.
|
2023-03-16 13:43:01 -03:00 |
|
Thales Macedo Garitezi
|
9037314aea
|
docs: improve descriptions
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
|
2023-03-16 13:43:01 -03:00 |
|
Thales Macedo Garitezi
|
1b78f22d92
|
docs: improve descriptions
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
|
2023-03-16 13:43:01 -03:00 |
|
Thales Macedo Garitezi
|
e1fdd041b3
|
feat(kafka_consumer): add `offset_commit_interval_seconds` kafka parameter
|
2023-03-16 13:43:01 -03:00 |
|
Thales Macedo Garitezi
|
969fa03ecc
|
feat: implement kafka consumer
|
2023-03-16 13:43:01 -03:00 |
|
Zaiming (Stone) Shi
|
ada68e12e6
|
fix(kafka): change default value for memory_overload_protection to false
|
2023-02-22 13:46:51 +01:00 |
|
Zaiming (Stone) Shi
|
157c919ba1
|
ci: add i18n style check script
|
2023-02-09 11:41:52 +01:00 |
|
Zaiming (Stone) Shi
|
d5c482b0b0
|
docs: remove timer unit from description
the user input has time unit. e.g. "5s" for 5 seconds etc.
|
2023-02-02 13:49:20 +01:00 |
|
Zhongwen Deng
|
1a90c1654c
|
chore: bad typo
|
2023-02-02 11:43:04 +08:00 |
|
Zaiming (Stone) Shi
|
a7fc5e8fe1
|
Merge pull request #9761 from zmstone/0114-fix-kafka-value-template-and-docs
feat: introduce 'this' concept for placeholder, and use it in Kafka bridge
|
2023-01-16 13:37:29 +01:00 |
|
Zaiming (Stone) Shi
|
47414e0d53
|
docs: improve kafka key and value field description
|
2023-01-16 11:32:09 +01:00 |
|
Zaiming (Stone) Shi
|
522e091dd2
|
docs: chane cache to buffer for Kafka bridge description
|
2023-01-13 07:46:23 +01:00 |
|
Zaiming (Stone) Shi
|
0ce1ca89b7
|
refactor: use string type for server and servers
|
2022-12-30 14:20:23 +01:00 |
|
Zaiming (Stone) Shi
|
a5e3f6f05b
|
fix(kafka): Memory OLP is only applicable in linux systems
|
2022-12-28 15:31:53 +01:00 |
|
Zaiming (Stone) Shi
|
e45c99bf79
|
fix: kafka bridge schema
|
2022-09-13 20:02:48 +02:00 |
|
Zaiming (Stone) Shi
|
0c1595be02
|
feat: Add Kafka connector
|
2022-09-13 19:46:56 +02:00 |