@Test public void shouldGetKey() { assertThat(record.key()).isEqualTo(4); }
@Override public K key() { return key; }
SnowdropConsumerRecord implements ConsumerRecord<K, V> { @Override public K key() { return key; } }
SnowdropConsumerRecord implements ConsumerRecord<K, V> { @Override public K key() { return key; } SnowdropConsumerRecord(KafkaConsumerRecord<K, V> delegate); }
SnowdropConsumerRecord implements ConsumerRecord<K, V> { @Override public K key() { return key; } SnowdropConsumerRecord(KafkaConsumerRecord<K, V> delegate); @Override String topic(); @Override int partition(); @Override long offset(); @Override long timestamp(); @Override TimestampType timestampType(); @Override K key(); @Override V value(); @Override List<Header> headers(); @Override boolean equals(Object o); @Override int hashCode(); @Override String toString(); }
SnowdropConsumerRecord implements ConsumerRecord<K, V> { @Override public K key() { return key; } SnowdropConsumerRecord(KafkaConsumerRecord<K, V> delegate); @Override String topic(); @Override int partition(); @Override long offset(); @Override long timestamp(); @Override TimestampType timestampType(); @Override K key(); @Override V value(); @Override List<Header> headers(); @Override boolean equals(Object o); @Override int hashCode(); @Override String toString();  }