45 Commits

Author	SHA1	Message	Date
Xie Han	92febf72b0	Change interface name and make it compatible.	2025-09-19 18:31:12 +08:00
Xie Han	9a1e00a25e	Add WFHttpChunkedClient.	2025-09-17 21:46:00 +08:00
Xie Han	06830ac14c	Hide DNS enum types from global space.	2025-06-27 22:37:17 +08:00
Xie Han	6eaf84fbbe	Add template type on WFTaskFactory::send_by_name()/signal_by_name().	2025-01-03 22:19:10 +08:00
Xie Han	59ac643ccb	Fix functions overload resolution.	2024-12-14 03:40:36 +08:00
Yundi339	f272c0e791	Support windows mingw (#1657)	2024-11-21 01:28:09 +08:00
Xie Han	2ab8e95bb2	Update windows branch codes.	2024-05-09 02:01:09 +08:00
Xie Han	37a3aec078	Optimize kafka client code structure.	2024-02-21 19:29:43 +08:00
kedixa	fefd0f5768	Support set_offset_timestamp for KafkaToppar in automatic mode (#1475)	2024-01-12 22:07:48 +08:00
Xie Han	d6153826a2	Fix some header files.	2024-01-09 17:48:42 +08:00
Xie Han	d69254ff19	Fix kafka compiling problem	2024-01-09 16:18:49 +08:00
Xie Han	d98090a405	Update windows kafka client.	2024-01-08 19:18:50 +08:00
Xie Han	72f0e11423	Add encoding for kafka sasl password	2023-09-21 19:59:30 +08:00
Xie Han	7dd352ac3d	Optimize Kafka client compare_topics	2023-07-05 21:10:28 +08:00
Xie Han	86ff9fbc1b	Optimize Kafka client to make tasks fail fast when servers down.	2023-06-27 22:11:26 +08:00
kedixa	856bc734c6	kafka bugfix: cannot fetch without group	2023-04-20 16:09:41 +08:00
Xie Han	0c0c51989b	Remove unused variable.	2023-03-30 19:32:13 +08:00
kedixa	fa026c139b	kafka bugfix, cgroup may be concurrently write by more than one task	2023-03-15 20:18:51 +08:00
Xie Han	b0eb71a54d	kafka bugfix for infinite wait for meta counter	2023-03-09 21:02:02 +08:00
Xie Han	23bd793f4c	Fix kafka scheme checking	2023-02-13 23:13:39 +08:00
XieHan	dff1112378	Fix kafka client double free bug	2022-12-23 17:28:51 +08:00
XieHan	78c64f39bf	Update kafka codes	2022-11-01 17:48:30 +08:00
kedixa	ecea9cbca6	set kafka correlation id	2022-06-24 17:52:45 +08:00
XieHan	d9ff108705	remove no-rtti flag for some files	2022-04-28 16:58:49 +08:00
zhuleiwang	a402084b86	kafka: update WFKafkaClient (windows)	2022-04-22 18:10:21 +08:00
zhuleiwang	afffb9ffec	kafka: update WFKafkaClient (windows)	2022-04-22 13:19:43 +08:00
zhuleiwang	3b42c9fe76	kafka: change return type for init and deinit (windows)	2022-04-22 11:32:52 +08:00
zhuleiwang	a69509b38e	kafka: update WFKafkaClient (windows)	2022-04-22 05:55:44 +08:00
zhuleiwang	be57f67d7f	kafka: fix bug for record ptr error when fetch (windows)	2022-04-17 17:51:22 +08:00
zhuleiwang	bef08956ea	kafka: refactor logic (windows)	2022-04-14 18:52:48 +08:00
wzl12356	1e01842f9e	Delete WFKafkaClient.cc.orig	2022-04-08 16:38:06 +08:00
wzl12356	204effa1b3	kafka: fix coredump when no meta	2022-04-08 15:52:12 +08:00
wzl12356	57bd0bec80	kafka: fix coredump when no meta	2022-04-07 11:53:19 +08:00
wzl12356	635381be6d	kafka: fix meta_callback set uninit state	2022-03-31 21:22:16 +08:00
wzl12356	66271ab2cf	kafka: fix offset not continuous when fetch	2022-03-18 13:42:53 +08:00
DengJun	abc8a02689	Merge branch 'windows' into kafka-win	2022-02-03 19:06:22 +08:00
dengjun	334a1450fa	fix compile error for kafka	2022-02-03 18:56:24 +08:00
wzl12356	246e89a5f7	kafka: set meta uninit when task failed	2022-01-06 17:58:33 +08:00
wzl12356	56bbc1148f	kafka: fix out of range error for fetch	2021-12-08 12:05:49 +08:00
wzl12356	4c885d5a4b	support kafka protocol	2021-12-07 12:21:41 +08:00
XieHan	c9007a13e3	fix bugs	2021-12-03 22:03:43 +08:00
XieHan	7ffc71960f	migrate asynchronous DNS resolving to windows branch	2021-10-28 18:46:27 +08:00
liyingxin	268c873d20	add define guard for WFMySQLConnection.h (#336)	2021-04-12 20:21:59 +08:00
wujiaxu	6f6dcd2f8d	add code for windows platform	2020-08-01 14:23:17 +08:00
XieHan	354ff7432b	initialization	2020-07-29 13:42:26 +08:00