जावा में संदेश में उपभोक्ता समूह को कैसे जोड़ा जाए?

Question

मैं संदेश भेजने के लिए जावा, बसंत और काफ्का
में नए मैं अगले कोड है हूँ

kafkaTemplate.send(topic, message); 

निर्माता के लिए मेरे विन्यास:

props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, 
      bootstrapServers); 
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, 
      IntegerSerializer.class); 
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, 
      StringSerializer.class); 
    // value to block, after which it will throw a TimeoutException 
    props.put(ProducerConfig.MAX_BLOCK_MS_CONFIG, 5000); 

मैं अपने उपभोक्ता समूह के साथ संदेश भेजना चाहते हैं (उदाहरण "MyConsumerGroup"),
लेकिन मुझे नहीं पता कि मैं इसे कैसे कर सकता हूं मदद के लिए धन्यवाद

Answer 1

अवधारणा "उपभोक्ता समूह" का केवल उपभोक्ताओं पर लागू होता है (जैसा नाम बताता है)। यदि आप काफ्का को एक संदेश लिखते हैं, तो कोई भी उपभोक्ता समूह बाद में संदेश पढ़ सकता है।

इस प्रकार, यदि आप एक संदेश लिखते हैं, तो उपभोक्ता समूह निर्दिष्ट करना संभव नहीं है क्योंकि इससे कोई अर्थ नहीं होगा।