KAFKA-17485: POC KIP-1088 KafkaClientInterceptor [DO NOT MERGE] #17333
Conversation
We don't pass in a client-supplier into `StreamsProducer` any longer, so we can simplify `StreamsProducerTest` and remove client-supplier.
| import java.util.HashMap; | ||
| import java.util.Map; | ||
|
|
||
| public class KafkaClientInterceptor implements Configurable { |
There was a problem hiding this comment.
Not sure if we would want to make this an interface similar to KafakClientSuppplier plus its impl class DefaultKafkaClientSupplier
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
Outdated
Show resolved
Hide resolved
…logyTestDriver.java
mumrah
added
the
do-not-merge
|
This PR is being marked as stale since it has not had any activity in 90 days. If you If you are having difficulty finding a reviewer, please reach out on the [mailing list](https://kafka.apache.org/contact). If this PR is no longer valid or desired, please feel free to close it. If no activity occurs in the next 30 days, it will be automatically closed. |
|
This PR has been closed since it has not had any activity in 120 days. If you feel like this |
The first commits are from #17330
Only
KAFKA-17485: POC KIP-1088 KafkaClientsSupplieris relevant.