Versions Compared

Old Version 4

changes.mady.by.user fu.jian

Saved on

compared with

New Version 5

changes.mady.by.user fu.jian

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

kafkaConsumerConfig.customConfig(ConsumerConfig.CLIENT_ID_CONFIG, generateClientIdWithRack(ip, rack));


Public Interfaces

...

Add rack ID support to org.apache.kafka.clients.admin.MemberDescription:


Code Block
languagejava
titleRemoteLogMetadataManagerMemberDescription
public class MemberDescription {
    private final String memberId;
    private final Optional<String> groupInstanceId;
    private final Optional<String> rackId;  // NEW FIELD
    private final String clientId;/**
 * Simple callback interface for broker ready notification.
 */
public interface BrokerReadyCallback {
    /**
private final String host; 
 * This method will//omit be called during broker startup for the implementationother codes
}

Add rack ID support to org.apache.kafka.clients.admin.MemberDescription:

Code Block
languagejava
title ShareMemberDescription 
public class MemberDescription {     
     * which needs delayed initialization until the broker can process requests.
     */
    void onBrokerReady();

}private final String memberId;
    private final Optional<String> rackId; // NEW FIELD 
    private final String clientId;
    private final String host;
    //omit other codes
}


public class ShareMemberDescription {add the interface into RemoteLogMetadataManager's implements with default implement.

Code Block
public interface RemoteLogMetadataManager extends BrokerReadyCallback, Configurable, Closeable

...