THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
package org.apache.kafka.clients.admin;
/**
* Options for {@link AdminClient#fenceProducersAdmin#fenceProducers(Collection, FenceProducersOptions)}
*
* The API of this class is evolving. See {@link AdminClientAdmin} for details.
*/
@InterfaceStability.Evolving
public class FenceProducersOptions extends AbstractOptions<FenceProducersOptions> {
// No options (yet) besides those inherited from AbstractOptions
} |
...
Summary: instead of expanding the AdminClientAdmin API to add producer-fencing functionality, just instantiate a throwaway producer for the sole purpose of calling Producer::initTransactions .
...