| Status | Fully Qualified Name |
| MODIFIED (!) | org.apache.kafka.clients.consumer.Consumer |
| MODIFIED | org.apache.kafka.clients.consumer.ConsumerConfig |
| NEW | org.apache.kafka.clients.consumer.ConsumerInterceptor |
| MODIFIED | org.apache.kafka.clients.consumer.ConsumerRecord |
| MODIFIED (!) | org.apache.kafka.clients.consumer.KafkaConsumer |
| MODIFIED (!) | org.apache.kafka.clients.consumer.MockConsumer |
| UNCHANGED (*) | org.apache.kafka.clients.consumer.NoOffsetForPartitionException |
| UNCHANGED (*) | org.apache.kafka.clients.consumer.OffsetOutOfRangeException |
| UNCHANGED (*) | org.apache.kafka.clients.consumer.RangeAssignor |
| UNCHANGED (*) | org.apache.kafka.clients.consumer.RoundRobinAssignor |
| MODIFIED | org.apache.kafka.clients.Metadata |
| MODIFIED | org.apache.kafka.clients.NetworkClient |
| MODIFIED | org.apache.kafka.clients.producer.ProducerConfig |
| NEW | org.apache.kafka.clients.producer.ProducerInterceptor |
| MODIFIED | org.apache.kafka.clients.producer.ProducerRecord |
| MODIFIED (!) | org.apache.kafka.clients.producer.RecordMetadata |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public abstract | void | assign(java.util.List) | n.a. |
|
|
||||||
| NEW (*) | public abstract | void | assign(java.util.Collection) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | pause(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW (*) | public abstract | void | pause(java.util.Collection) | n.a. |
|
|
||||||
| NEW (*) | public abstract | java.util.Set | paused() | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | resume(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW (*) | public abstract | void | resume(java.util.Collection) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | seekToBeginning(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW (*) | public abstract | void | seekToBeginning(java.util.Collection) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | seekToEnd(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW (*) | public abstract | void | seekToEnd(java.util.Collection) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | subscribe(java.util.List) | n.a. |
|
|
||||||
| REMOVED (!) | public abstract | void | subscribe(java.util.List,
| n.a. |
|
|
||||||
| NEW (*) | public abstract | void | subscribe(java.util.Collection) | n.a. |
|
|
||||||
| NEW (*) | public abstract | void | subscribe(java.util.Collection,
| n.a. |
|
|
| Status: | Fully Qualified Name: | Elements: |
| REMOVED | org.apache.kafka.common.annotation.InterfaceStability$Unstable | n.a. |
| Status | Modifier | Type | Field | Compatibility Changes: |
| MODIFIED | public (<- private ) static final | java.lang.String | n.a. | AUTO_OFFSET_RESET_DOC |
| NEW | public static final | java.lang.String | n.a. | EXCLUDE_INTERNAL_TOPICS_CONFIG |
| NEW | public static final | boolean | n.a. | EXCLUDE_INTERNAL_TOPICS_DEFAULT |
| NEW | public static final | java.lang.String | n.a. | INTERCEPTOR_CLASSES_CONFIG |
| NEW | public static final | java.lang.String | n.a. | INTERCEPTOR_CLASSES_DOC |
| NEW | public static final | java.lang.String | n.a. | MAX_POLL_RECORDS_CONFIG |
| Change |
| INTERFACE_ADDED |
| Status | Interface | Compatibility Changes: |
| NEW | org.apache.kafka.common.Configurable | n.a. |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||
| NEW | public abstract | void | close() | n.a. | n.a. |
|
||||
| NEW | public abstract | void | onCommit(java.util.Map) | n.a. | n.a. |
|
||||
| NEW | public abstract | org.apache.kafka.clients.consumer.ConsumerRecords | onConsume(org.apache.kafka.clients.consumer.ConsumerRecords) | n.a. | n.a. |
|
| Status | Modifier | Type | Field | Compatibility Changes: |
| NEW | public static final | long | n.a. | NO_TIMESTAMP |
| NEW | public static final | int | n.a. | NULL_CHECKSUM |
| NEW | public static final | int | n.a. | NULL_SIZE |
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||
| NEW | public | ConsumerRecord(java.lang.String,
| n.a. | n.a. |
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||
| NEW | public | long | checksum() | n.a. | n.a. |
|
||||
| NEW | public | int | serializedKeySize() | n.a. | n.a. |
|
||||
| NEW | public | int | serializedValueSize() | n.a. | n.a. |
|
||||
| NEW | public | long | timestamp() | n.a. | n.a. |
|
||||
| NEW | public | org.apache.kafka.common.record.TimestampType | timestampType() | n.a. | 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. |
|
|
||||||
| NEW | public | void | assign(java.util.Collection) | n.a. | n.a. |
|
||||||
| REMOVED (!) | public | void | pause(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW | public | void | pause(java.util.Collection) | n.a. | n.a. |
|
||||||
| NEW | public | java.util.Set | paused() | n.a. | n.a. |
|
||||||
| REMOVED (!) | public | void | resume(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW | public | void | resume(java.util.Collection) | n.a. | n.a. |
|
||||||
| REMOVED (!) | public | void | seekToBeginning(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW | public | void | seekToBeginning(java.util.Collection) | n.a. | n.a. |
|
||||||
| REMOVED (!) | public | void | seekToEnd(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW | public | void | seekToEnd(java.util.Collection) | n.a. | n.a. |
|
||||||
| REMOVED (!) | public | void | subscribe(java.util.List,
| n.a. |
|
|
||||||
| REMOVED (!) | public | void | subscribe(java.util.List) | n.a. |
|
|
||||||
| NEW | public | void | subscribe(java.util.Collection,
| n.a. | n.a. |
|
||||||
| NEW | public | void | subscribe(java.util.Collection) | n.a. | n.a. |
|
| Status: | Fully Qualified Name: | Elements: |
| REMOVED | org.apache.kafka.common.annotation.InterfaceStability$Unstable | 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. |
|
|
||||||
| NEW | public | void | assign(java.util.Collection) | n.a. | n.a. |
|
||||||
| REMOVED (!) | public | void | pause(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW | public | void | pause(java.util.Collection) | n.a. | n.a. |
|
||||||
| REMOVED (!) | public | void | resume(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW | public | void | resume(java.util.Collection) | n.a. | n.a. |
|
||||||
| REMOVED (!) | public | void | seekToBeginning(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW | public | void | seekToBeginning(java.util.Collection) | n.a. | n.a. |
|
||||||
| REMOVED (!) | public | void | seekToEnd(org.apache.kafka.common.TopicPartition[]) | n.a. |
|
|
||||||
| NEW | public | void | seekToEnd(java.util.Collection) | n.a. | n.a. |
|
||||||
| REMOVED (!) | public | void | subscribe(java.util.List) | n.a. |
|
|
||||||
| REMOVED (!) | public | void | subscribe(java.util.List,
| n.a. |
|
|
||||||
| NEW | public | void | subscribe(java.util.Collection) | n.a. | n.a. |
|
||||||
| NEW | public | void | subscribe(java.util.Collection,
| n.a. | n.a. |
|
| Change |
| METHOD_ABSTRACT_ADDED_IN_SUPERCLASS |
| Serializable | default serialVersionUID | serialVersionUID in class | |
| Old | true | -2792422368992172539 | 1 |
| New | true | -2792422368992172539 | 1 |
| Change |
| METHOD_ABSTRACT_ADDED_IN_SUPERCLASS |
| Serializable | default serialVersionUID | serialVersionUID in class | |
| Old | true | 2540990097304481188 | 1 |
| New | true | 2540990097304481188 | 1 |
| Change |
| METHOD_ABSTRACT_ADDED_IN_SUPERCLASS |
| Change |
| METHOD_ABSTRACT_ADDED_IN_SUPERCLASS |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||
| NEW | public | boolean | updateRequested() | n.a. | n.a. |
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||
| NEW | static public | org.apache.kafka.common.protocol.types.Struct | parseResponse(java.nio.ByteBuffer,
| n.a. | n.a. |
|
| Status | Modifier | Type | Field | Compatibility Changes: |
| NEW | public static final | java.lang.String | n.a. | INTERCEPTOR_CLASSES_CONFIG |
| NEW | public static final | java.lang.String | n.a. | INTERCEPTOR_CLASSES_DOC |
| Change |
| INTERFACE_ADDED |
| Status | Interface | Compatibility Changes: |
| NEW | org.apache.kafka.common.Configurable | n.a. |
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||
| NEW | public abstract | void | close() | n.a. | n.a. |
|
||||
| NEW | public abstract | void | onAcknowledgement(org.apache.kafka.clients.producer.RecordMetadata,
| n.a. | n.a. |
|
||||
| NEW | public abstract | org.apache.kafka.clients.producer.ProducerRecord | onSend(org.apache.kafka.clients.producer.ProducerRecord) | n.a. | n.a. |
|
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||
| NEW | public | ProducerRecord(java.lang.String,
| n.a. | n.a. |
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||
| NEW | public | java.lang.Long | timestamp() | n.a. | n.a. |
|
| Status | Modifier | Type | Field | Compatibility Changes: |
| NEW | public static final | int | n.a. | UNKNOWN_PARTITION |
| Status | Modifier | Constructor | Exceptions | Compatibility Changes: | Line Number | ||||||
| REMOVED (!) | public | RecordMetadata(org.apache.kafka.common.TopicPartition,
| n.a. |
|
|
||||||
| NEW | public | RecordMetadata(org.apache.kafka.common.TopicPartition,
| n.a. | n.a. |
|
| Status | Modifier | Type | Method | Exceptions | Compatibility Changes: | Line Number | ||||
| NEW | public | long | checksum() | n.a. | n.a. |
|
||||
| NEW | public | int | serializedKeySize() | n.a. | n.a. |
|
||||
| NEW | public | int | serializedValueSize() | n.a. | n.a. |
|
||||
| NEW | public | long | timestamp() | n.a. | n.a. |
|
||||
| NEW | public | java.lang.String | toString() | n.a. | n.a. |
|