1

For example, let's say there is a discrepancy in offsets.retention.minutes, what setting becomes effective, from which broker? Does each broker have its own setting for partitions of __consumer_offsets that are hosted by that broker?

EDIT: Apparently, I didn't understand what is offsets.retention.minutes setting for, I think I realized it after reading this question on SO.

I didn't understand the difference between that setting, and log.retention.minutes config for __consumer_offset topic, but now I think I do. Still, there may be some other settings that may be problematic if not set same on each broker in cluster?

hdjur_jcv
  • 686
  • 1
  • 12
  • 30
  • Why would you like to have Kafka brokers with different configuration? – Giorgos Myrianthous Mar 08 '19 at 15:44
  • It's not that I would like it, I just wonder what happens if accidentally someone configures it differently. Is there some mechanism to prevent that? Or is there a mechanism that deals with that, built into Kafka cluster code? – hdjur_jcv Mar 11 '19 at 16:52

0 Answers0