There is no built-in support for Apache Kafka in Pega 7. With that said, can you post your code showing what you are able to get?

For example :

for (kafka.consumer.KafkaStream<byte[], byte[]> stream : consumerMap.get(topic)) {
	kafka.consumer.ConsumerIterator<byte[], byte[]> it = stream.iterator();
	while (it.hasNext()){
           String messageId = new String(it.next().message());
           //process 
	}
}
consumer.shutdown();

Also, how are your properties set up?

props.put("partition.assignment.strategy", "range");

props.put("auto.offset.reset", "smallest");

Read the doc and am testing on my 7.3 ref. system. From what I see so far, those two values are not part of the dataset. The Kafka Consumer API for reading a message also does not provide them - and that is what I suspect Pega is employing (as opposed to AdminClient). Will research further and reach out internally.

So, one of the SMEs suspects it might be available from Consumer API but we are not exposing it. I asked about options to discover and he stated its all internal code, so very difficult to access from any sort of local change. I have another SME resource who is part of the team working on the 7.4 modifications - so I'll reach out in that direction.

This is not supported. Pega development is curious as to what use case you have that requires you to get offset and partition after publishing. Can you provide that?

While pushing a message on kafka topic, that message is stored in some partition and offset. I need that partition and offset number to check what actually posted from pega and also for our automation testing we need. We have another get rest service to check the posted message on topic using this offset and partition number.