Chapter 5. Deprecated features
The features deprecated in this release, and that were supported in previous releases of AMQ Streams, are outlined below.
5.1. Kafka Connect with Source-to-Image (S2I)
With the introduction of build
configuration to the KafkaConnect resource, AMQ Streams can now automatically build a container image with the connector plugins you require for your data connections.
As a result, support for Kafka Connect with Source-to-Image (S2I) is deprecated.
To prepare for this change, you can migrate Kafka Connect S2I instances to Kafka Connect instances.
5.2. EnableECDSA property
The enableECDSA
property has been deprecated in the oauth
listener configuration for the Kafka broker. The value of this property is now ignored.
ECDSA encryption is available through the Java Cryptography Extension (JCE). The Bouncy Castle Crypto libraries are no longer packaged with AMQ Streams.
5.3. Inclusive language
The topicsBlacklistPattern
and groupsBlacklistPattern
properties in the KafkaMirrorMaker2
resource are deprecated. The properties will be removed and replaced by topicsExcludePattern
and groupsExcludePattern
.
The whitelist
property in the KafkaMirrorMaker
resource is deprecated. The property will be replaced by include
.
5.4. Kafka Connect naming of plugin artifact files
The Kafka Connect build process now uses the URL hash to name downloaded artifact files. Previously, it used the last segment of the download URL.
5.5. Deprecated and removed Kafka features
This section gives advance notice of important deprecations and removals in the Apache Kafka project.
5.5.1. Planned for removal in Kafka version 3.0
Kafka version 3.0 will be shipped with the next major release of AMQ Streams.
The following table shows methods and components that were deprecated in Kafka 2.x or earlier and will be removed in Kafka 3.0. This list is not exhaustive.
API or component | Issue link | Description |
---|---|---|
Admin API | Remove deprecated Admin.electPreferredLeaders | |
Admin API | Reimplement KafkaFuture with CompletableFuture (deprecate KafkaFuture.Function) | |
Admin client |
Remove deprecated | |
All clients | Remove various deprecated methods from clients for 3.0 | |
All clients |
Remove deprecated config value | |
All clients | Remove deprecated security classes/methods | |
Broker |
Remove deprecated | |
Broker | Remove deprecated LogConfig.Compact | |
Broker | Remove deprecated SimpleAclAuthorizer | |
Broker | Remove PrincipalBuilder and DefaultPrincipalBuilder | |
Common |
Removed deprecated | |
Consumer API | Remove deprecated PartitionAssignor interface | |
Connect API | Remove deprecated rest.host.name and rest.port Connect worker configs | |
Connect API | Remove port, host.name, and related configs in 3.0 | |
Connect API | Remove internal converter config properties | |
Streams API | Deprecate eos-alpha | |
Streams API | Remove deprecated methods under StreamsMetrics | |
Streams API | Remove deprecated options from StreamsResetter | |
Streams API |
Removal of deprecated classes under | |
Streams API | Remove deprecated APIs of Kafka Streams in 3.0 | |
Streams API | Remove deprecated methods on WindowStore | |
Streams API | Remove deprecated WindowStore#put | |
Streams API | Remove deprecated schedule method in ProcessorContext | |
Streams API | Remove deprecated methods under Stores | |
Streams API | Remove deprecated method StreamsConfig#getConsumerConfig | |
Streams API | Deprecate the default.windowed.serde.inner.class configs | |
Streams API | Remove deprecated RocksDB#compactRange API | |
Streams API |
Remove deprecated | |
Streams API | Remove deprecated "UsePreviousTimeOnInvalidTimeStamp" | |
Streams API | Remove deprecated TopologyDescription.Source#topics | |
Streams API | Remove deprecated KafkaClientSupplier#getAdminClient | |
Streams API | Deprecated PartitionGrouper config is ignored | |
Streams API | Remove deprecated "TopologyTestDriver#pipeInput / readOutput" | |
Streams API | Remove deprecated methods StreamsBuilder#addGlobalStore | |
Streams API | Remove deprecated overloads for ProcessorContext#forward | |
Streams API | Remove deprecated methods from ReadOnlyWindowStore | |
Streams API | Remove deprecated Count and SampledTotal in 3.0 | |
Streams API | Remove deprecation annotation on long-based read operations in WindowStore | |
Streams API | Remove deprecated "KStream#groupBy/join", "Joined#named" overloads | |
Streams API | Migrate TaskMetadata to interface with internal implementation | |
Streams API | Remove PartitionGrouper interface and it’s config and move DefaultPartitionGrouper to internal package | |
Streams API | Remove segment/segmentInterval from Window definition | |
Streams API | Increase Version of RocksDB | |
Streams API | Allow users to opt-into spurious left/outer stream-stream join improvement | |
Tools |
Remove deprecated | |
Tools | Remove deprecated --zookeeper in shell commands |
5.5.2. Mirror Maker 1.0 planned for removal in Kafka version 4.0
Kafka version 4.0 will be shipped in a future major release of AMQ Streams.
The following table shows a feature that will be deprecated in Kafka 3.0 and removed in Kafka 4.0.
Component | Link to issue | Summary |
---|---|---|
Mirror Maker 1.0 | deprecate MirrorMaker v1 |