Hi John,
Thanks for the question!
That method is used when the Connector notifies the runtime it observed an
event that would require a new set of task configs.
For example, the MirrorSourceConnector calls
ConnectorContext#requestTaskReconfiguration() when a new topic appears in
the input cluster, so that the new topic may be allocated to a source task.
The Herder#requestTaskReconfiguration(String) method is an internal method
used to implement that part of the API.
Could you be more specific about the error you're seeing?
Thanks,
Greg
On Mon, Jun 24, 2024 at 3:25 AM <talljhawk...@gmail.com> wrote:
> Hi Folks,
>
> Any ideas?
>
>
>
> From: talljhawk...@gmail.com <talljhawk...@gmail.com>
> Sent: Thursday, June 13, 2024 10:36 AM
> To: dev@kafka.apache.org
> Subject: Herder#requestTaskReconfiguration
>
>
>
> Hi Folks,
>
> what is the purpose of this method please?
>
>
>
> /**
>
> * Requests reconfiguration of the tasks of a connector. This should
> only be triggered by
>
> * {@link HerderConnectorContext}.
>
> *
>
> * @param connName name of the connector that should be reconfigured
>
> */
>
> void requestTaskReconfiguration(String connName);
>
>
>
>
>
> In my quest to create a stable standalone herder - this method is being
> called by the Jdbc adapter and causes the herder to blow an exception as it
> ends up trying to create a task which has already been created.
>
>
>
> Many thanks,
>
> John.
>
>
>
>
