Skip to content
Closed
Show file tree
Hide file tree
Changes from 2 commits
Commits
Show all changes
29 commits
Select commit Hold shift + click to select a range
d9bab79
MINOR: remove unneccessary public keyword from ProducerInterceptor in…
May 23, 2021
efb7cda
MINOR: update java doc for deprecated methods (#10722)
showuon May 24, 2021
c92e62a
MINOR: Add log identifier/prefix printing in Log layer static functio…
kowshik May 24, 2021
33df5c6
MINOR: clarify message ordering with max in-flight requests and idemp…
ableegoldman May 24, 2021
39f4e0c
MINOR: remove unneccessary public keyword from ConsumerInterceptor in…
May 25, 2021
63b6db3
KAFKA-12800: Configure generator to fail on trailing JSON tokens (#10…
cursedquail May 25, 2021
77573d8
MINOR: add window verification to sliding-window co-group test (#10745)
mjsax May 26, 2021
e4f2f6f
KAFKA-12260: Avoid hitting NPE for partitionsFor (#10017)
May 26, 2021
38e8391
MINOR: Log more information when producer snapshot is written (#10757)
dajac May 26, 2021
bbe170a
MINOR: deprecate TaskMetadata constructor and add KIP-740 notes to up…
ableegoldman May 26, 2021
47094ef
MINOR: Log constructor: Flip logical NOT for readability (#10756)
kowshik May 26, 2021
db288e4
Update implementation.html (#10771)
prince-mahajan May 27, 2021
56d9482
KAFKA-12819: Add assert messages to MirrorMaker tests plus other qual…
mdedetrich May 27, 2021
a02b19c
KAFKA-12796: Removal of deprecated classes under streams-scala (#10710)
jlprat May 27, 2021
e4b3a3c
MINOR: Adjust parameter ordering of `waitForCondition` and `retryOnEx…
ijuma May 27, 2021
3fb836f
MINOR: Improve Log layer segment iteration logic and few other areas …
kowshik May 27, 2021
2313026
KAFKA-12856: Upgrade Jackson to 2.12.3 (#10778)
ijuma May 27, 2021
6659777
MINOR: Don't ignore deletion of partition metadata file and log topic…
ijuma May 27, 2021
5cbe6a7
KAFKA-12791: ConcurrentModificationException in AbstractConfig use by…
lbradstreet May 27, 2021
a6f3094
MINOR: make sure all fiedls of o.p.k.s.a.Action are NOT null (#10764)
chia7712 May 28, 2021
588ea44
KAFKA-12782: Fix Javadocs generation by upgrading JDK (#10780)
jlprat May 28, 2021
f207bac
KAFKA-8410: KTableProcessor migration groundwork (#10744)
vvcephei May 28, 2021
0bf4b47
MINOR: upgrade pip from 20.2.2 to 21.1.1 (#10661)
chia7712 May 29, 2021
99a0312
KAFKA-12865 : Fix doc error in Admin.describeAcls API (#10790)
rohit-sachan May 29, 2021
6b005b2
MINOR: Reduce allocations in requests via buffer caching (#9229)
ijuma May 30, 2021
6c9e27c
HOTFIX: fix build error (#10796)
chia7712 May 31, 2021
ee88bf6
MINOR: remove unneccessary public keyword from ProducerInterceptor in…
May 23, 2021
dcc83c2
MINOR: remove unneccessary public keyword from ConsumerInterceptor in…
May 25, 2021
5e6f627
Merge remote-tracking branch 'origin/trunk' into trunk
May 31, 2021
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ public interface ConsumerInterceptor<K, V> extends Configurable, AutoCloseable {
* @param records records to be consumed by the client or records returned by the previous interceptors in the list.
* @return records that are either modified by the interceptor or same as records passed to this method.
*/
public ConsumerRecords<K, V> onConsume(ConsumerRecords<K, V> records);
ConsumerRecords<K, V> onConsume(ConsumerRecords<K, V> records);

/**
* This is called when offsets get committed.
Expand All @@ -74,10 +74,10 @@ public interface ConsumerInterceptor<K, V> extends Configurable, AutoCloseable {
*
* @param offsets A map of offsets by partition with associated metadata
*/
public void onCommit(Map<TopicPartition, OffsetAndMetadata> offsets);
void onCommit(Map<TopicPartition, OffsetAndMetadata> offsets);

/**
* This is called when interceptor is closed
*/
public void close();
void close();
}
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ public interface ProducerInterceptor<K, V> extends Configurable {
* @param record the record from client or the record returned by the previous interceptor in the chain of interceptors.
* @return producer record to send to topic/partition
*/
public ProducerRecord<K, V> onSend(ProducerRecord<K, V> record);
ProducerRecord<K, V> onSend(ProducerRecord<K, V> record);

/**
* This method is called when the record sent to the server has been acknowledged, or when sending the record fails before
Expand All @@ -86,10 +86,10 @@ public interface ProducerInterceptor<K, V> extends Configurable {
* {@link org.apache.kafka.clients.producer.KafkaProducer#send(ProducerRecord)}.
* @param exception The exception thrown during processing of this record. Null if no error occurred.
*/
public void onAcknowledgement(RecordMetadata metadata, Exception exception);
void onAcknowledgement(RecordMetadata metadata, Exception exception);

/**
* This is called when interceptor is closed
*/
public void close();
void close();
}