Skip to content

Commit

Permalink
Revert "Added configurable ProducerRecord to ConsumerRecord mapper. T…
Browse files Browse the repository at this point in the history
…he default mapper does not include metadata and headers. Alternative mappers can now be specified."

Reapplied without previous reformatting.

This reverts commit 0589e41.
  • Loading branch information
sivanmz committed Jan 23, 2020
1 parent 0589e41 commit bf4135f
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -116,7 +116,7 @@ public Future<RecordMetadata> send(ProducerRecord<K, V> r, Callback callback) {
} else {
final Future<RecordMetadata> f = super.send(r, (metadata, exception) -> {
if (callback != null) callback.onCompletion(metadata, exception);
ConsumerRecord<K, V> consumerRecord = recordMapper.apply(r, metadata);
final ConsumerRecord<K, V> consumerRecord = recordMapper.apply(r, metadata);
enqueue(consumerRecord);
});
return f;
Expand Down

0 comments on commit bf4135f

Please sign in to comment.