anchor.diff:      @Override
       public void configure() throws Exception {
           from("kafka:" + TOPIC + "?brokers=localhost:{{kafkaPort}}" +
  -                     "&groupId=A" +                            //
  -                     "&autoOffsetReset=earliest" +             // Ask to start from the beginning if we have unknown offset
  -                     "&offsetRepository=#offsetRepo")          // Keep the offsets in the previously configured repository
  +                     // Setup the topic and broker address
  +                     "&groupId=A" +
  +                     // The consumer processor group ID
  +                     "&autoOffsetReset=earliest" +
  +                     // Ask to start from the beginning if we have unknown offset
  +                     "&offsetRepository=#offsetRepo")
  +                     // Keep the offsets in the previously configured repository
                   .to("mock:result");
       }
   });
  
positive.code:     @Override
      public void configure() throws Exception {
          from("kafka:" + TOPIC + "?brokers=localhost:{{kafkaPort}}" +
                       "&groupId=A" +                            //
                       "&sslContextParameters=#ssl")             // Reference the SSL configuration
                  .to("mock:result");
      }
  });
  
negative.code: [source,xml]
  ----
  <!-- simple -->
  <bean id="insertDbIdemRepo"
    class="org.apache.camel.processor.idempotent.kafka.KafkaIdempotentRepository">
    <property name="topic" value="idempotent-db-inserts"/>
    <property name="bootstrapServers" value="localhost:9091"/>
  </bean>
  
  <!-- complex -->
  <bean id="insertDbIdemRepo"
    class="org.apache.camel.processor.idempotent.kafka.KafkaIdempotentRepository">
    <property name="topic" value="idempotent-db-inserts"/>
    <property name="maxCacheSize" value="10000"/>
    <property name="consumerConfig">
  