| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public abstract | void | assign(java.util.List) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | pause(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | resume(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | seekToBeginning(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | seekToEnd(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | subscribe(java.util.List) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | subscribe(java.util.List,
| n.a. |
|
|
| Status | Interface | Compatibility Changes: |
| UNCHANGED (!) | org.apache.kafka.clients.consumer.Consumer | n.a. |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | void | assign(java.util.List) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | pause(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | resume(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | seekToBeginning(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | seekToEnd(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | subscribe(java.util.List,
| n.a. |
|
|
||||||
| REMOVED (!) | public | void | subscribe(java.util.List) | n.a. |
|
|
| Status | Interface | Compatibility Changes: |
| UNCHANGED (!) | org.apache.kafka.clients.consumer.Consumer | n.a. |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | void | assign(java.util.List) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | pause(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | resume(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | seekToBeginning(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | seekToEnd(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | subscribe(java.util.List) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | subscribe(java.util.List,
| n.a. |
|
|
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | RecordMetadata(org.apache.kafka.common.TopicPartition,
| n.a. |
|
|
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | AbstractConfig(org.apache.kafka.common.config.ConfigDef,
| n.a. |
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| MODIFIED (!) | public | java.lang.Boolean (<- boolean) | getBoolean(java.lang.String) | n.a. |
|
|
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | ConfigDef$ConfigKey(java.lang.String,
| n.a. |
|
|
| Serializable | default serialVersionUID | serialVersionUID in class | |
| Old | true | -611604104574502833 | n.a. |
| New | true | -8022639404396770552 | n.a. |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | java.util.concurrent.TimeUnit | timeUnit() | n.a. |
|
|
||||||
| REMOVED (!) | public | org.apache.kafka.common.metrics.MetricConfig | timeUnit(java.util.concurrent.TimeUnit) | n.a. |
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | static public | org.apache.kafka.common.network.ChannelBuilder | create(org.apache.kafka.common.protocol.SecurityProtocol,
| n.a. |
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||||||
| MODIFIED (!) | public | boolean (<- void) | finishConnect() |
|
|
|
| Status | Interface | Compatibility Changes: |
| UNCHANGED (!) | org.apache.kafka.common.network.TransportLayer | n.a. |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||||||
| MODIFIED (!) | public | boolean (<- void) | finishConnect() |
|
|
|
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | SaslChannelBuilder(org.apache.kafka.common.network.Mode,
| n.a. |
|
|
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | Selector(long,
| n.a. |
|
|
| Status | Interface | Compatibility Changes: |
| UNCHANGED (!) | org.apache.kafka.common.network.TransportLayer | n.a. |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||||||
| MODIFIED (!) | public | boolean (<- void) | finishConnect() |
|
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||||||
| MODIFIED (!) | public abstract | boolean (<- void) | finishConnect() |
|
|
|
| Serializable | default serialVersionUID | serialVersionUID in class | |
| Old | true | -8035427831674922723 | n.a. |
| New | true | 1250769155262369273 | n.a. |
| Serializable | default serialVersionUID | serialVersionUID in class | |
| Old | true | -5125543860899509861 | n.a. |
| New | true | -1654754384850777816 | n.a. |
| Status | Modifier | Type | Field | Compatibility Changes: | ||
| REMOVED (!) | public static final | org.apache.kafka.common.protocol.types.Schema (!) |
| BROKER |
| Serializable | default serialVersionUID | serialVersionUID in class | |
| Old | true | 4968843793818681341 | n.a. |
| New | true | -2864593231814898886 | n.a. |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | void | putRecord(byte[],
| n.a. |
|
|
||||||
| REMOVED (!) | public | void | putRecord(byte[],
| n.a. |
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | void | append(long,
| n.a. |
|
|
| Status | Modifier | Type | Field | Compatibility Changes: | ||
| REMOVED (!) | public static final | int (!) |
| KEY_OFFSET | ||
| REMOVED (!) | public static final | int (!) |
| KEY_SIZE_OFFSET |
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | Record(byte[],
| n.a. |
|
|
||||||
| REMOVED (!) | public | Record(byte[]) | n.a. |
|
|
||||||
| REMOVED (!) | public | Record(byte[],
| n.a. |
|
|
||||||
| REMOVED (!) | public | Record(byte[],
| n.a. |
|
|
||||||
| REMOVED (!) | public | Record(byte[],
| n.a. |
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | static public | long | computeChecksum(byte[],
| n.a. |
|
|
||||||
| REMOVED (!) | static public | void | write(java.nio.ByteBuffer,
| n.a. |
|
|
||||||
| REMOVED (!) | static public | void | write(org.apache.kafka.common.record.Compressor,
| n.a. |
|
|
| Change |
| CLASS_REMOVED |
| SUPERCLASS_REMOVED |
| Status | Modifier | Type | Field | Compatibility Changes: | ||
| REMOVED (!) | public final | java.lang.String (!) |
| host | ||
| REMOVED (!) | public final | int (!) |
| id | ||
| REMOVED (!) | public final | int (!) |
| port |
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | LeaderAndIsrRequest$EndPoint(int,
| n.a. |
|
|
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | MetadataResponse(org.apache.kafka.common.Cluster,
| n.a. |
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | boolean | hasError(java.lang.String) | n.a. |
|
|
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | ProduceResponse$PartitionResponse(short,
| n.a. |
|
|
| Change |
| CLASS_REMOVED |
| SUPERCLASS_REMOVED |
| Status | Modifier | Type | Field | Compatibility Changes: | ||
| REMOVED (!) | public final | java.lang.String (!) |
| host | ||
| REMOVED (!) | public final | int (!) |
| id | ||
| REMOVED (!) | public final | int (!) |
| port |
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | UpdateMetadataRequest$BrokerEndPoint(int,
| n.a. |
|
|
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | SaslClientAuthenticator(java.lang.String,
| n.a. |
|
|
| Change |
| CLASS_REMOVED |
| SUPERCLASS_REMOVED |
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | SaslClientAuthenticator$ClientCallbackHandler() | n.a. |
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | void | handle(javax.security.auth.callback.Callback[]) | n.a. |
|
|
| Serializable | default serialVersionUID | serialVersionUID in class | |
| Old | true | -4068099564071267284 | n.a. |
| New | true | 918008074165263001 | n.a. |
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | SaslServerAuthenticator(java.lang.String,
| n.a. |
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | static public | java.lang.String | defaultRealm() | n.a. |
|
|
| Change |
| CLASS_REMOVED |
| SUPERCLASS_REMOVED |
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | Login(java.lang.String,
| n.a. |
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | void | shutdown() | n.a. |
|
|
||||||
| REMOVED (!) | public | void | startThreadIfNeeded() | n.a. |
|
|
||||||
| REMOVED (!) | public | javax.security.auth.Subject | subject() | n.a. |
|
|
| Change |
| CLASS_REMOVED |
| SUPERCLASS_REMOVED |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | final static public | org.apache.kafka.common.security.kerberos.LoginManager | acquireLoginManager(org.apache.kafka.common.network.LoginType,
| n.a. |
|
|
||||||
| REMOVED (!) | static public | void | closeAll() | n.a. |
|
|
||||||
| REMOVED (!) | public | void | release() | n.a. |
|
|
||||||
| REMOVED (!) | public | java.lang.String | serviceName() | n.a. |
|
|
||||||
| REMOVED (!) | public | javax.security.auth.Subject | subject() | n.a. |
|
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | static public | java.lang.Thread | newThread(java.lang.String,
| n.a. |
|
|
||||||
| REMOVED (!) | static public | void | writetUnsignedInt(java.nio.ByteBuffer,
| n.a. |
|
|