code: public Observable<EventHubConsumerGroupInfoInner> createEventHubConsumerGroupAsync(String resourceGroupName, String resourceName, String eventHubEndpointName, String name) {
          return createEventHubConsumerGroupWithServiceResponseAsync(resourceGroupName, resourceName, eventHubEndpointName, name).map(new Func1<ServiceResponse<EventHubConsumerGroupInfoInner>, EventHubConsumerGroupInfoInner>() {
              @Override
              public EventHubConsumerGroupInfoInner call(ServiceResponse<EventHubConsumerGroupInfoInner> response) {
                  return response.body();
              }
          });
      }
docs: Add a consumer group to an Event Hub-compatible endpoint in an IoT hub.
  Add a consumer group to an Event Hub-compatible endpoint in an IoT hub.
  
  @param resourceGroupName The name of the resource group that contains the IoT hub.
  @param resourceName The name of the IoT hub.
  @param eventHubEndpointName The name of the Event Hub-compatible endpoint in the IoT hub.
  @param name The name of the consumer group to add.
  @throws IllegalArgumentException thrown if parameters fail the validation
  @return the observable to the EventHubConsumerGroupInfoInner object