diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/Grouped.java b/streams/src/main/java/org/apache/kafka/streams/kstream/Grouped.java
index c196d933c40ea..44b074082016d 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/Grouped.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Grouped.java
@@ -14,10 +14,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.kafka.streams.kstream;
 
-
 import org.apache.kafka.common.serialization.Serde;
 
 /**
@@ -35,7 +33,6 @@ public class Grouped<K, V> implements NamedOperation<Grouped<K, V>> {
     protected final Serde<V> valueSerde;
     protected final String name;
 
-
     private Grouped(final String name,
                     final Serde<K> keySerde,
                     final Serde<V> valueSerde) {
@@ -71,7 +68,7 @@ public static <K, V> Grouped<K, V> as(final String name) {
      * @see KStream#groupBy(KeyValueMapper, Grouped)
      * @see KTable#groupBy(KeyValueMapper, Grouped)
      */
-    public static <K> Grouped keySerde(final Serde<K> keySerde) {
+    public static <K, V> Grouped<K, V> keySerde(final Serde<K> keySerde) {
         return new Grouped<>(null, keySerde, null);
     }
 
@@ -85,7 +82,7 @@ public static <K> Grouped keySerde(final Serde<K> keySerde) {
      * @see KStream#groupBy(KeyValueMapper, Grouped)
      * @see KTable#groupBy(KeyValueMapper, Grouped)
      */
-    public static <V> Grouped valueSerde(final Serde<V> valueSerde) {
+    public static <K, V> Grouped<K, V> valueSerde(final Serde<V> valueSerde) {
         return new Grouped<>(null, null, valueSerde);
     }