Page History

{
  "apiKey": TBD,
  "type": "response",
  "name": "ConsumerGroupInstallAssignment",
  "validVersions": "0",
  "flexibleVersions": "0+",
  // Supported errors:
  // - GROUP_AUTHORIZATION_FAILED
    "about": "The metadata bytes." }
    ]}
  ]
}

{
    "type": "data",
    "name": "ConnectWorkerGroupMetadataKey",
    "validVersions": "3",
    "flexibleVersions": "none",
    "fields": [
          { "name": "GroupId", "type": "string", "versions": "3" }
    ]
}

{
    "type": "data",
    "name": "ConnectWorkerGroupMetadataValue",
    "validVersions": "0",
    "flexibleVersions": "0+",
    "fields": [
        { "name": "Epoch", "versions": "0+", "type": "int32" }
    ], 
}

{
    "type": "data",
    "name": "ConnectWorkerGroupConnectorsTasksMetadataKey",
    "validVersions": "4",
    "flexibleVersions": "none",
    "fields": [
          { "name": "GroupId", "type": "string", "versions": "4" }
    ]
}

{
    "type": "data",
    "name": "SubscribedTopicNamesConnectWorkerGroupTargetAssignmentKey",
    "versionsvalidVersions": "0+6",
    "typeflexibleVersions": "[]string" },
none",
    "fields": [
          { "name": "SubscribedTopicRegexGroupId", "versionstype": "0+string", "typeversions": "string5" },
    ]
}

{
    { "nametype": "Assignorsdata",
    "versionsname": "0+GroupTargetAssignmentValue",
    "validVersions": "0",
      "typeflexibleVersions": "[]Assignor0+",
    "fields": [
            { "name": "NameAssignmentEpoch", "versions": "0+", "type": "stringint32" },
            { "name": "MinimumVersionMembers", "versions": "0+", "type": "int16" },[]Member", "fields": [
            { "name": "MaximumVersionMemberId", "versions": "0+", "type": "int16string" },
            { "name": "ReasonError", "versions": "0+", "type": "int8" },
            { "name": "VersionConnectorsTasks", "versions": "0+", "type": "int16" },[]ConnectorsTasks", "fields": 
            [
              { "name": "MetadataConnectors", "versions": "0+", "type": "bytes[]String" },
          ]}
    ], 
}

{
    "{ "name": "AssignmentEpoch", "versions": "0+", "type": "int32data" },
        { "name": "MembersConnectWorkerGroupCurrentMemberAssignmentKey",
    "versionsvalidVersions": "0+7",
    "typeflexibleVersions": "[]Membernone",
    "fields": [
            { "name": "MemberIdGroupId", "versionstype": "0+string", "typeversions": "string7" },
            { "name": "ErrorMemberId", "versionstype": "0+string", "typeversions": "int87" },
    ]
}

{
    "type": "data",
    { "name": "ConnectorsTasksGroupCurrentMemberAssignmentValue",
    "versionsvalidVersions": "0+",
    "typeflexibleVersions": "[]ConnectorsTasks0+",
    "fields": 
            [
              { "name": "ConnectorsMemberEpoch", "versions": "0+", "type": "[]Stringint32" },
              { "name": "TasksError", "versions": "0+", "type": "[]ConnectorsTasks" }
            ]
       int8" },
         { "name": "VersionConnectorsTasks", "versions": "0+", "type": "[]ConnectorsTasks", "int16" },fields": 
            [
              { "name": "MetadataConnectors", "versions": "0+", "type": "bytes[]String" },
        ]
    ]
}

{
    "type": "data",
  {  "name": "ConnectWorkerGroupConfigurationValue",
    "validVersions": "Error",0",
    "versionsflexibleVersions": "0+",
    "typefields": "int8" },[
        { "name": "ConnectorsTasksConfigurations", "versions": "0+", "type": "[]ConnectorsTasksConfiguration", "fields": 
           "fields": [
              { "name": "ConnectorsName", "versionstype": "0+string", "typeversions": "[]String" }0+",
              {  "nameabout": "Tasks", "versions": "0+", "type": "[]ConnectorsTasks" }The name of the configuration key." },
            ]
        },
        { "name": "VersionValue", "versionstype": "0+string", "typeversions": "int160+" },
            {   "nameabout": "Metadata", "versions": "0+", "type": "bytes" The value of the configuration." }
        ]}
    ], 
}

package org.apache.kafka.clients.consumer;

import org.apache.kafka.common.TopicIdPartition;
import org.apache.kafka.common.Uuid;

import java.nio.ByteBuffer;
import java.util.List;
import java.util.Optional;

public interface Assignor {

    class Group {
        /**
         * The members.
         */
        List<GroupMember> members;
    }

    class GroupMember {
        /**
         * The member ID.
         */
        String memberId;

        /**
         * The instance ID if provided.
         */
        Optional<String> instanceId;

package org.apache.kafka.clients.consumer;

import org.apache.kafka.common.TopicIdPartition;
import org.apache.kafka.common.Uuid;

import java.nio.ByteBuffer;
import java.util.List;
import java.util.Optional;

public interface Assignor {

    class Group {
        /**
         * The members reason reported by the member.
         */
        List<GroupMember>byte membersreason;

    }

    class/**
 GroupMember {
        /**
 The version of the metadata encoded in  * The member ID{{@link GroupMember#metadata()}}.
         */
        Stringint memberIdversion;

        /**
         * The instance ID if providedcustom metadata provided by the member as defined
         * by {{@link PartitionAssignor#metadata()}}.
         */
        ByteBuffer metadata;

    }

    class Optional<String>Assignment instanceId;{

        /**
         * The reason reported by the memberassignment error.
         */
        byte reasonerror;

        /**
         * The version of the metadata encoded in {{@link GroupMember#metadata()}}member assignment.
         */
        intList<MemberAssignment> versionmembers;

        /**}

    class MemberAssignment   {
 * The custom metadata provided by the member as defined /**
         * byThe {{@link PartitionAssignor#metadata()}}member ID.
         */
        ByteBufferString metadatamemberId;

    }

    class Assignment {
        /**
         * The assignment errorerror reported by the assignor.
         */
        byte error;

        /**
         * The memberversion assignment.
of the metadata encoded in     */{{@link GroupMember#metadata()}}.
        List<MemberAssignment> members;*/
    }

    class MemberAssignmentint {version;

        /**
         * The member IDcustom metadata provided by the assignor.
         */
        StringByteBuffer memberIdmetadata;
    }

    class Metadata {
        /**
         * The errorreason reported by the assignor.
         */
        byte errorreason;

        /**
         * The version of the metadata encoded in {{@link GroupMember#metadataMetadata#metadata()}}.
         */
        int version;

        /**
         * The custom metadata provided by the assignor.
         */
        ByteBuffer metadata;
    }

    /**
    class Metadata { * Unique name for this assignor.
     */
    String name();

    /**
     * The minimum version.
     */
    int minimumVersion();

    /**
     * The maximum version.
     */
    int maximumVersion();

    /**
     * Return serialized data *that Thewill reasonbe reportedsent byto the assignor.
         */
        byte reasonMetadata metadata();

        /**
     * Perform the  * The version of the metadata encoded in {{@link Metadata#metadata()}}group assignment given the current members and
     * topic metadata.
     *
     */
 @param group The group state.
   int version;

 * @return The new assignment for the /**group.
     */
     * The custom metadata provided by the assignor.
         */
   Assignment assign(Group group);

    /**
     * Callback which is invoked when the member received a new
     ByteBuffer* metadata;
assignment from the assignor/group }coordinator.

     */**
    void * Unique name for this assignor.
     */
    String name();

    /**
onAssignment(MemberAssignment assignment);

}

package org.apache.kafka.connect.runtime;

import org.apache.kafka.clients.consumer.Assignor;
import org.apache.kafka.connect.runtime.distributed.ExtendedAssignment;
import org.apache.kafka.connect.runtime.distributed.ExtendedWorkerState;
import org.apache.kafka.connect.runtime.distributed.WorkerCoordinator;

import java.util.List;

public interface ConnectAssignor {

    class Group {

	 /**
         * The minimum versionmembers.
         */
      int minimumVersion()  List<GroupMember> members;

        /**
     * The maximum version.
 * Connector's and tasks */metadata.
    int maximumVersion();

    */**
     * Return serialized data that will be sent to the assignor.
     */WorkerCoordinator.ConnectorsAndTasks connectorsAndTasks;
    }

	class GroupMember {
    Metadata metadata();

    /**
     * Perform the group assignment* givenThe the current members andmember ID.
     * topic metadata.
     */
     * @param group The group state.String memberId;

     * @return The new/**
 assignment for the group.
      */
 The instance ID Assignment assign(Group group);

if provided.
    /**
     */
   Callback which is invoked when the member received a new
Optional<String> instanceId;

        /**
 assignment from the assignor/group coordinator.
     */
 The reason reported voidby onAssignment(MemberAssignment assignment);

}