diff --git a/kafka/hbase-kafka-proxy/src/main/java/org/apache/hadoop/hbase/kafka/KafkaBridgeConnection.java b/kafka/hbase-kafka-proxy/src/main/java/org/apache/hadoop/hbase/kafka/KafkaBridgeConnection.java index bcb6704a..83eb9740 100644 --- a/kafka/hbase-kafka-proxy/src/main/java/org/apache/hadoop/hbase/kafka/KafkaBridgeConnection.java +++ b/kafka/hbase-kafka-proxy/src/main/java/org/apache/hadoop/hbase/kafka/KafkaBridgeConnection.java @@ -187,6 +187,14 @@ public TableBuilder setWriteRpcTimeout(int timeout) { return null; } + /** + * This method was added in HBASE-27657. We donot add @Override to allow code to compile with + * versions of hbase both having and not having HBASE-27657 + **/ + public TableBuilder setRequestAttribute(String key, byte[] value) { + return null; + } + @Override public Table build() { return new KafkaTableForBridge(tn, passedInConfiguration, routingRules, producer,