f7498a40f2
MINOR: fix broken link in javadoc ( #17526 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-10-18 00:50:27 +08:00
2353a7c508
KAFKA-17723 Fix "this-escape" compiler warnings (MultiThreadedEventProcessor and DistributedHerder) for JDK 23 ( #17417 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-10-11 21:28:27 +08:00
b03fe66cfe
KAFKA-17759 Remove Utils.mkSet ( #17460 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-10-11 21:20:43 +08:00
6d650ff9e5
KAFKA-17534: Add configuration to disable the heartbeats topic replication ( #17413 )
...
Introducing heartbeats.replication.enabled to explicitly disable the default heartbeats topic replication.
This change implements KIP-1089.
Reviewers: Viktor Somogyi-Vass <viktorsomogyi@gmail.com>
2024-10-10 14:21:36 +02:00
3815339e05
KAFKA-14158: Remove auto.include.jmx.reporter configuration ( #17360 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-10-08 16:17:07 +02:00
5624bc7c7e
MINOR: Remove hamcrest from connect:runtime, raft and server-common ( #17394 )
...
Reviewers: David Arthur <mumrah@gmail.com>
2024-10-08 14:22:45 +02:00
9e809be4ce
KAFKA-17529 Remove blacklist from MM2 ( #17202 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-10-07 13:21:31 +08:00
d38a90df2b
KAFKA-17672 Run quarantined tests separately ( #17329 )
...
Introduce new quarantinedTest that excludes tests tagged with "flaky". Also introduce two new build parameters "maxQuarantineTestRetries" and "maxQuarantineTestRetryFailures".
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-10-06 14:09:24 +08:00
3bb408c4de
MINOR: rename ConfigName.RENAME to ConfigName.RENAMES for replaceFiled ( #17369 )
...
Reviewers: Andrew Schofield <aschofield@confluent.io>, TengYao Chi <kitingiao@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
2024-10-05 05:50:48 +08:00
979740b49d
KAFKA-17589 Move JUnit extensions to test-common module ( #17318 )
...
This patch completely removes the compile-time dependency on core for both test and main sources by introducing two new modules.
1) `test-common` include all the common test implementation code (including dependency on :core for BrokerServer, ControllerServer, etc)
2) `test-common:api` new sub-module that just includes interfaces including our junit extension
Reviewers: David Arthur <mumrah@gmail.com>
2024-10-03 10:28:37 +08:00
7fb25a2b06
KAFKA-16769 Remove add.source.alias.to.metrics configuration ( #17323 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-10-02 02:03:02 +08:00
818ee8a581
KAFKA-17078: Add SecurityManagerCompatibility shim ( #16522 )
...
Signed-off-by: Greg Harris <greg.harris@aiven.io>
Reviewers: José Armando García Sancio <jsancio@apache.org>, Omnia Ibrahim <o.g.h.ibrahim@gmail.com>, Chris Egerton <fearthecellos@gmail.com>, Luke Chen <showuon@gmail.com>, David Arthur <mumrah@gmail.com>
2024-09-30 08:06:14 -07:00
db56553fd3
KAFKA-17530 Remove blacklist/whitelist from ReplaceField ( #17237 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-09-25 01:02:28 +08:00
70f7418660
MINOR: Increase logging verbosity in Connect integration tests ( #17189 )
...
This patch increases the verbosity of the logging in Connect's integration tests. This is to better understand the causes of the flaky tests described in KAFKA-17493.
Reviewers: Chris Egerton <chrise@aiven.io>
2024-09-14 00:04:46 -07:00
9242723e4c
KAFKA-17435 remove use.incremental.alter.configs ( #17027 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-09-11 14:34:05 +08:00
50e7022a1b
MINOR: Improve error message when Connect's EmbeddedKafkaCluster::verifyClusterReadiness method fails ( #16918 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-09-07 10:23:59 -04:00
a39037e55c
KAFKA-17399 Apply LambdaValidator to code base ( #16980 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-08-26 21:53:49 +08:00
b40b5a24f4
KAFKA-17369: Remove Reflections from logging and update licenses ( #16924 )
...
Reviewers: Mickael Maison <mickael.maison@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
2024-08-19 16:27:36 -07:00
e24354a21d
KAFKA-15203: Use Classgraph since org.reflections is no longer under maintenance ( #16604 )
...
Reviewers: Liam Miller-Cushon <cushon@google.com>, Greg Harris <greg.harris@aiven.io>
2024-08-19 10:46:24 -07:00
4763d0fc30
KAFKA-17242: Do not log spurious timeout message for MirrorCheckpointTask sync store startup ( #16773 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-08-08 10:03:42 -04:00
0dc74c5556
KAFKA-17232: Do not generate task configs in MirrorCheckpointConnector if initial consumer group load times out ( #16767 )
...
Reviewers: Hongten <hongtenzone@foxmail.com>, Chris Egerton <chrise@aiven.io>
2024-08-08 09:58:11 -04:00
8152ee6519
MINOR: Increase test producer max.block.ms in MirrorConnectorsIntegrationTransactionsTest ( #16785 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-08-05 14:37:17 -04:00
3f3e376797
MINOR: Fix stage recording in DistributedHerder::addRequest ( #16784 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-08-05 14:36:39 -04:00
39b1586f93
MINOR: Fix ConnectWorkerIntegrationTest::testRequestTimeouts ( #16772 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-08-02 16:41:34 -04:00
5afdb17092
MINOR: Fix consumer group warmup in MirroMaker 2 integration tests ( #16771 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-08-02 13:57:05 -04:00
a524609f4c
MINOR: Add extended cluster readiness check for Connect's embedded Kafka cluster ( #16757 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-08-01 16:12:57 -04:00
8d8c367066
KAFKA-17192 Fix MirrorMaker2 worker config does not pass config.provi… ( #16678 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-07-31 16:50:22 -04:00
342bd2844f
MINOR: Unify Log4j levels across Connect runtime and MirrorMaker 2 integration tests ( #16733 )
...
Reviewers: Yash Mayya <yash.mayya@gmail.com>
2024-07-31 12:07:38 +02:00
7c0a96d08d
KAFKA-17185 Declare Loggers as static to prevent multiple logger instances ( #16680 )
...
As discussed in #16657 (comment) , we should make logger as static to avoid creating multiple logger instances.
I use the regex private.*Logger.*LoggerFactory to search and check all the results if certain logs need to be static.
There are some exceptions that loggers don't need to be static:
1) The logger in the inner class. Since java8 doesn't support static field in the inner class.
https://github.com/apache/kafka/blob/trunk/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetchRequestManagerTest.java#L3676
2) Custom loggers for each instance (non-static + non-final). In this case, multiple logger instances is actually really needed.
https://github.com/apache/kafka/blob/trunk/storage/src/test/java/org/apache/kafka/server/log/remote/storage/LocalTieredStorage.java#L166
3) The logger is initialized in constructor by LogContext. Many non-static but with final modifier loggers are in this category, that's why I use .*LoggerFactory to only check the loggers that are assigned initial value when declaration.
4) protected final Logger log = Logger.getLogger(getClass())
This is for subclass can do logging with subclass name instead of superclass name.
But in this case, if the log access modifier is private, the purpose cannot be achieved since subclass cannot access the log defined in superclass. So if access modifier is private, we can replace getClass() with <className>.class
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-07-31 02:37:36 +08:00
61f61d6240
KAFKA-14569: Migrate Connect's integration test EmbeddedKafkaCluster from ZK to KRaft mode ( #16599 )
...
Reviewers: Omnia Ibrahim <o.g.h.ibrahim@gmail.com>, Mickael Maison <mickael.maison@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>
2024-07-29 10:43:55 -04:00
738d8cc91e
MINOR: Update bootstrap.servers doc string ( #16655 )
...
Reviewers: Mickael Maison <mickael.maison@gmail.com>
2024-07-26 15:08:01 +02:00
956d740c46
KAFKA-16068: Use TestPlugins mechanism in ConnectorValidationIntegrationTest to prevent ERROR-level log spam in unrelated test suites ( #16647 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-07-23 13:15:03 -04:00
defcbb51ee
KAFKA-17082 replace kafka.utils.LogCaptureAppender with org.apache.kafka.common.utils.LogCaptureAppender ( #16601 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-07-21 18:22:05 +08:00
208bb1fbc2
MINOR: Add integration test for plugin aliases ( #16621 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-07-19 12:47:41 -04:00
c97421c100
KAFKA-17150: Use Utils.loadClass instead of Class.forName to resolve aliases correctly ( #16608 )
...
Signed-off-by: Greg Harris <greg.harris@aiven.io>
Reviewers: Chris Egerton <chrise@aiven.io>, Chia-Ping Tsai <chia7712@gmail.com>, Josep Prat <josep.prat@aiven.io>
2024-07-17 16:00:45 -07:00
53ec055394
KAFKA-17105: Prevent redundant restarts for newly-created connectors ( #16581 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-07-17 14:33:47 -04:00
177b38ad66
KAFKA-16383: Ensure tasks have already polled their consumers before producing verified records in MirrorConnectorsIntegrationBaseTest::testReplicateFromLatest ( #16598 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-07-16 19:42:31 -04:00
6cffed56f6
KAFKA-16943: Synchronously verify Connect worker startup failure in InternalTopicsIntegrationTest ( #16451 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-07-16 14:20:44 -04:00
808498e939
KAFKA-14401: Fail kafka log read end requests if underneath work thread fails ( #14372 )
...
Reviewers: Chris Egerton <chrise@aiven.io>
2024-07-15 20:55:52 -04:00
6e9c039eea
KAFKA-17097 Add replace.null.with.default configuration to ValueToKey and ReplaceField ( #16571 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-07-15 18:12:59 +08:00
83081652ab
MINOR: Fix ConnectWorkerIntegrationTest::testBrokerCoordinator ( #16585 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-07-13 03:48:19 -04:00
3f43d27483
KAFKA-17111: explicitly register Afterburner module in JsonSerializer and JsonDeserializer ( #16565 )
...
Reviewers: Mickael Maison <mickael.maison@gmail.com>, Josep Prat <josep.prat@aiven.io>, Greg Harris <greg.harris@aiven.io>
2024-07-11 14:17:27 +02:00
0781151794
KAFKA-16254: Allow MM2 to fully disable offset sync feature ( #15999 )
...
Reviewers: Mickael Maison <mickael.maison@gmail.com>, Chris Egerton <fearthecellos@gmail.com>, Chia-Ping Tsai <chia7712@gmail.com>, Igor Soarez <soarez@apple.com>
2024-07-09 12:38:03 +02:00
515cdbb707
MINOR: Fix retry logic in DedicatedMirrorIntegrationTest::awaitTaskConfigurations ( #16525 )
...
Reviewers: Greg Harris <greg.harris@aiven.io>
2024-07-08 14:51:23 -04:00
e2ec389a7c
KAFKA-15838: KIP-1040: Add replace.null.with.default to InsertField, ExtractField, HeaderFrom, Cast, SetSchemaMetadata, TimestampConverter, MaskField transforms ( #15756 )
...
Reviewers: Mickael Maison <mickael.maison@gmail.com>, Greg Harris <greg.harris@aiven.io>
2024-07-08 11:09:54 -07:00
27220d146c
KAFKA-10816: Add health check endpoint for Kafka Connect ( #16477 )
...
Reviewers: Greg Harris <gharris1727@gmail.com>
2024-07-03 14:15:15 -04:00
4550550c7c
MINOR: Cleanup TestPlugins and normalize TestPlugin enum ( #13333 )
...
Signed-off-by: Greg Harris <greg.harris@aiven.io>
Reviewers: Chris Egerton <chrise@aiven.io>
2024-07-03 09:44:09 -07:00
e93242283d
KAFKA-15917: Wait for zombie sink tasks' consumers to commit offsets before trying to modify their offsets in integration tests ( #15302 )
...
Reviewers: Yash Mayya <yash.mayya@gmail.com>, Greg Harris <greg.harris@aiven.io>
2024-07-03 10:25:23 -04:00
6897b06b03
KAFKA-3346 Rename Mode to ConnectionMode ( #16403 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-07-03 02:46:04 +08:00
645eefe95a
KAFKA-17007 Fix SourceAndTarget#equal ( #16416 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-21 20:52:07 +08:00
0772144e51
MINOR: Add javadoc for Connect public packages/classes ( #16404 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-21 10:23:35 +02:00
8d92535382
KAFKA-10787 apply spotless to connect:runtime module ( #16412 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-21 16:04:51 +08:00
4de6a90801
KAFKA-16921 [6/N] Remove junit 4 dependency from connect:runtime module ( #16383 )
...
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
2024-06-19 14:39:16 +08:00
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
Kuan-Po Tseng
Anshul Goyal
Gaurav Narula
Dániel Urbán
Mickael Maison
Chia-Chuan Yu
David Arthur
TaiJuWu
Chia-Ping Tsai
Greg Harris
David Jacot
Xuan-Zhang Gong
Chris Egerton
xijiu
Steven Xu
Dmitry Werner
TengYao Chi
Chris Egerton
Kondrat Bertalan
Chung, Ming-Yen
PaulRMellor
PoAn Yang
Zhengke Zhou
vamossagar12
Vikas Balani
Omnia Ibrahim
Fiore Mario Vitale
abhi-ksolves
gongxuanzhang
Ken Huang
Ken Huang
dujian0068
Ivan Yurchenko
Johnny Hsu
Farbod Ahmadian
Sanskar Jhajharia
Fan Yang
Edoardo Comar
Yash Mayya
Ivan Yurchenko
yuz10
Jorge Esteban Quilcate Otoya
Hector Geraldino
Calvin Liu