Class KafkaPropertyAdapter


  • public class KafkaPropertyAdapter
    extends java.lang.Object
    Wrapper around a Properties making them easier to consume
    • Constructor Detail

      • KafkaPropertyAdapter

        public KafkaPropertyAdapter​(java.lang.String instanceIdentifier,
                                    java.lang.String topicName,
                                    java.util.Properties properties,
                                    KafkaPropertyAdapter.Mode mode)
        Public constructor
        Parameters:
        instanceIdentifier -
        topicName -
        properties -
        mode -
    • Method Detail

      • putPropertiesTo

        public void putPropertiesTo​(java.util.Properties kafkaProps)
        Fill the given kafkaProperties object with the configuration properties held by this adapter
        Parameters:
        kafkaProps -
      • getTopicName

        public java.lang.String getTopicName()
        Returns:
        the topicName
      • getInstanceIdentifier

        public java.lang.String getInstanceIdentifier()
        Returns:
        the instanceIdentifier