d5592d8fe6
KAFKA-16921 [5/N] Migrate test of connect module to Junit5 (Runtime subpackage) ( #16350 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-18 18:20:14 +08:00
3a3f9ce48e
KAFKA-16921 [4/N] Migrate test of connect module to Junit5 (Runtime direct) ( #16351 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-18 18:09:40 +08:00
fc6f8b6591
KAFKA-16921 [3/N] migrate connect module to junit 5 ( #16330 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-15 00:37:59 +08:00
8682334b6a
KAFKA-16921 [2/N] migrate connect module to junit 5 ( #16328 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-15 00:25:41 +08:00
133f2b0f31
KAFKA-16879 SystemTime should use singleton mode ( #16266 )
...
Reviewers: Greg Harris <gharris1727@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
2024-06-14 08:49:19 +08:00
6af937639d
KAFKA-16076 Fix Missing thread interrupt call in RestClient class ( #16282 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-14 08:07:13 +08:00
ea60666513
KAFKA-16921 [1/N] Migrate all junit 4 code to junit 5 for connect module ( #16253 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-13 16:11:37 +08:00
596b945072
KAFKA-16643 Add ModifierOrder checkstyle rule ( #15890 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-13 15:39:32 +08:00
9ddd58bd6c
MINOR: Add readiness check for connector and separate Kafka cluster in ExactlyOnceSourceIntegrationTest::testSeparateOffsetsTopic ( #16306 )
...
Reviewers: Greg Harris <gharris1727@gmail.com>
2024-06-12 23:43:33 -04:00
e76e1da5ea
KAFKA-16935: Automatically wait for cluster startup in embedded Connect integration tests ( #16288 )
...
Reviewers: Greg Harris <gharris1727@gmail.com>
2024-06-12 20:18:23 -04:00
dd755b7ea9
KAFKA-8206: KIP-899: Allow client to rebootstrap ( #13277 )
...
This commit implements KIP-899: Allow producer and consumer clients to rebootstrap. It introduces the new setting `metadata.recovery.strategy`, applicable to all the types of clients.
Reviewers: Greg Harris <gharris1727@gmail.com>, Rajini Sivaram <rajinisivaram@googlemail.com>
2024-06-12 20:48:32 +01:00
79b9c44acd
KAFKA-10787 Apply spotless to connect module ( #16299 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-12 22:19:47 +08:00
2fa2c72581
MINOR: Wait for embedded clusters to start before using them in Connect OffsetsApiIntegrationTest ( #16286 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-06-11 17:15:07 -04:00
ac2a642ba9
MINOR: Fix flaky test ConnectWorkerIntegrationTest::testReconfigureConnectorWithFailingTaskConfigs ( #16273 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-06-11 15:13:35 -04:00
eec8fd6a98
KAFKA-9228: Restart tasks on runtime-only connector config changes ( #16053 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-06-10 17:02:08 -04:00
271a1b42cd
KAFKA-16223 Migrate KafkaConfigBackingStoreTest to Mockito ( #16126 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-07 07:02:14 +08:00
52514a89e3
KAFKA-16858: Throw DataException from validateValue on array and map schemas without inner schemas ( #16161 )
...
Signed-off-by: Greg Harris <greg.harris@aiven.io>
Reviewers: Chris Egerton <chrise@aiven.io>
2024-06-05 11:35:32 -07:00
0409003c43
KAFKA-16837, KAFKA-16838: Ignore task configs for deleted connectors, and compare raw task configs before publishing them ( #16122 )
...
Reviewers: Mickael Maison <mickael.maison@gmail.com>
2024-06-04 09:36:24 -04:00
5cbc1d616a
KAFKA-16881: InitialState type leaks into the Connect REST API OpenAPI spec ( #16175 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-06-03 13:34:58 -04:00
9eb05fc729
KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest ( #16164 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-02 20:32:54 +08:00
966f2eb3ef
Minor: Add URL to log for Connect RestClient ( #16166 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-06-01 16:25:16 -04:00
e974914ca5
MINOR: Code Cleanup - Connect Module ( #16066 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-05-31 04:55:00 +08:00
32b2b73f67
KAFKA-16844: Add ByteBuffer support for Connect ByteArrayConverter ( #16101 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-05-30 11:26:25 -04:00
3f3f3ac155
MINOR: Delete KafkaSecurityConfigs class ( #16113 )
...
Reviewers: Omnia Ibrahim <o.g.h.ibrahim@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
2024-05-30 05:55:24 +08:00
64f699aeea
KAFKA-15853: Move general configs out of KafkaConfig ( #16040 )
...
Reviewers: Mickael Maison <mickael.maison@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
2024-05-28 16:22:54 +02:00
11ad5e8bca
MINOR: Refactor Values class to fix checkstyle, add benchmark, optimize exceptions ( #15469 )
...
Signed-off-by: Greg Harris <greg.harris@aiven.io>
Reviewers: Mickael Maison <mickael.maison@gmail.com>
2024-05-23 13:23:18 -07:00
0ba15ad4d1
KAFKA-15905 Restarts of MirrorCheckpointTask should not permanently i… ( #15910 )
...
* KAFKA-15905 Restarts of MirrorCheckpointTask should not permanently interrupt offset translation
MirrorCheckpointTask reloads the last checkpoint at start,
OffsetSyncStore stores OffsetSyncs before reading till end.
If CheckpointTask cannot read checkpoints at startup,
use previous OffsetSyncStore load logic, with
warning log message about degraded offset translation.
Also addresses KAFKA-16622 Mirromaker2 first Checkpoint not emitted until
consumer group fully catches up once because the OffsetSyncStore store
is populated before reading to log end.
Co-Authored-By: Adrian Preston <prestona@uk.ibm.com>
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-05-23 17:17:56 +01:00
476d323f5a
KAFKA-16197: Print Connect worker specific logs on poll timeout expiry ( #15305 )
...
Reviewers: Luke Chen <showuon@gmail.com>, Greg Harris <greg.harris@aiven.io>
2024-05-20 17:00:04 -07:00
6aac009a2d
MINOR: Remove deprecated constructors from Connect's Kafka*BackingStore classes ( #15865 )
...
- These constructors were deprecated over 3 years ago in KAFKA-10021: Changed Kafka backing stores to use shared admin client to get end offsets and create topics #9780 .
- While these classes are not a part of Connect's public API, deprecation was still introduced instead of outright removal because they are useful utility classes that might've been used outside of Connect.
- The KafkaOffsetBackingStore's deprecated constructor was removed in KAFKA-14785: Connect offset read REST API #13434 .
- This patch removes the deprecated constructors for KafkaConfigBackingStore and KafkaStatusBackingStore.
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-05-18 04:09:30 +08:00
93a5efc4b7
KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest ( #15933 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-05-18 04:01:27 +08:00
7453549314
KAFKA-16671 enable test for ensureInternalEndpointIsSecured ( #15868 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-05-15 12:49:36 +08:00
e1771448cf
MINOR: Add coverage for MM2 heartbeats topic detection ( #15932 )
...
Reviewers: Greg Harris <gharris1727@gmail.com>
2024-05-14 10:11:34 +02:00
0cfc2983a5
KAFKA-16684: Fix flaky DedicatedMirrorIntegrationTest ( #15906 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-05-10 14:42:26 -04:00
5a9ccb6b77
KAFKA-16445: Add PATCH method for connector config ( #6934 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-05-09 21:59:09 +02:00
5f933ac840
MINOR: Correct connector scheduled rebalance logs ( #15875 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-05-08 12:32:47 +08:00
525b9b1d76
KAFKA-15018: Write connector tombstone offsets to secondary store before primary store ( #13801 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-05-07 14:29:02 -04:00
a4c6cefd10
KAFKA-14226: Introduce FieldPath abstraction and nested path support for ExtractField SMT ( #15379 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-05-07 14:07:18 -04:00
05df10449e
KAFKA-13328, KAFKA-13329 (2): Add custom preflight validation support for connector header, key, and value converters ( #14309 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-05-07 11:30:57 -04:00
55a00be4e9
MINOR: Replaced Utils.join() with JDK API. ( #15823 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-05-06 15:13:01 +08:00
41f5bf844d
KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest (2/3) ( #15841 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-05-06 08:47:17 +08:00
b8b2415d5e
KAFKA-16592 Add a new constructor which invokes the existing constructor with default value for alternativeString ( #15762 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-04-24 20:58:29 +08:00
1b301b3020
KAFKA-15853 Move socket configs into org.apache.kafka.network.SocketServerConfigs ( #15772 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-04-23 17:39:36 +08:00
ecb2dd4cdc
KAFKA-15853 Move KafkaConfig log properties and docs out of core ( #15569 )
...
Reviewers: Mickael Maison <mickael.maison@gmail.com>, Nikolay <nizhikov@apache.org>, Federico Valeri <fvaleri@redhat.com>, Chia-Ping Tsai <chia7712@gmail.com>
2024-04-20 04:14:23 +08:00
53ff1a5a58
KAFKA-15585: DescribeTopicPartitions client side change. ( #15470 )
...
Add the support for DescribeTopicPartitions API to AdminClient. For this initial implementation, we are simply loading all of the results into memory on the client side.
Reviewers: Andrew Schofield <aschofield@confluent.io>, Kirk True <ktrue@confluent.io>, David Jacot <djacot@confluent.io>, Artem Livshits <alivshits@confluent.io>, David Arthur <mumrah@gmail.com>
2024-04-18 12:09:14 -04:00
aee9724ee1
MINOR: Remove unneeded explicit type arguments ( #15736 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-04-17 21:55:58 +02:00
7b1c777b33
MINOR: Various cleanups in connect ( #15734 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-04-17 20:47:25 +08:00
363f4d2847
KAFKA-15853 Move consumer group and group coordinator configs out of core ( #15684 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-04-17 20:41:22 +08:00
a1ca788c99
KAFKA-15517: Improve MirrorMaker logging in case of authorization errors ( #15558 )
...
Reviewers: Mickael Maison <mickael.maison@gmail.com>
2024-04-16 12:09:14 +02:00
8c0458861c
KAFKA-15853 Move KafkaConfig Replication properties and docs out of … ( #15575 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-04-16 15:28:35 +08:00
2118d85805
KAFKA-16223 Replace EasyMock/PowerMock with Mockito for KafkaConfigBackingStoreTest (1/3) ( #15520 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-03-29 15:39:36 -07:00
TingIāu "Ting" Kì
gongxuanzhang
Ken Huang
PoAn Yang
dujian0068
abhi-ksolves
Chris Egerton
Ivan Yurchenko
Johnny Hsu
Greg Harris
Chia Chuan Yu
Farbod Ahmadian
Sanskar Jhajharia
Fan Yang
Mickael Maison
Omnia Ibrahim
Edoardo Comar
vamossagar12
Yash Mayya
Ivan Yurchenko
yuz10
Jorge Esteban Quilcate Otoya
Hector Geraldino
Calvin Liu
Dmitry Werner