You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2025/02/08 05:27:40 UTC
(kafka) branch 4.0 updated: MINOR: make leaking public member in StreamsConfig non-private
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 4.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/4.0 by this push:
new 562ecf4a83c MINOR: make leaking public member in StreamsConfig non-private
562ecf4a83c is described below
commit 562ecf4a83c2fa3577c45eba02328a1bfb751c2a
Author: Matthias J. Sax <ma...@confluent.io>
AuthorDate: Fri Feb 7 21:23:10 2025 -0800
MINOR: make leaking public member in StreamsConfig non-private
KIP-1112 specified PROCESSOR_WRAPPER_CLASS_DOC as `private` and it should not be public.
We need to make to package-private though, to allow TopologyConfig to use it.
---
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
index 7f1e460c711..b92431ed2be 100644
--- a/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
+++ b/streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
@@ -682,7 +682,7 @@ public class StreamsConfig extends AbstractConfig {
/** {@code processor.wrapper.class} */
public static final String PROCESSOR_WRAPPER_CLASS_CONFIG = "processor.wrapper.class";
- public static final String PROCESSOR_WRAPPER_CLASS_DOC = "A processor wrapper class or class name that implements the <code>org.apache.kafka.streams.state.ProcessorWrapper</code> interface. "
+ static final String PROCESSOR_WRAPPER_CLASS_DOC = "A processor wrapper class or class name that implements the <code>org.apache.kafka.streams.state.ProcessorWrapper</code> interface. "
+ "Must be passed in to the StreamsBuilder or Topology constructor in order to take effect";
/** {@code repartition.purge.interval.ms} */