Page History

...

Users currently need to type in a HashMap for connection properties on Producers, Consumers and Consumers.AdminClient

Example:

Map<String, Object> config = new HashMap<>();
config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9999");
config.put(ConsumerConfig.RECEIVE_BUFFER_CONFIG, -2);
KafkaConsumer consumer = new KafkaConsumer<>(config, new ByteArrayDeserializer(), new ByteArrayDeserializer());

...

KafkaConsumer consumer = new KafkaConsumer("localhost:9999,localhost2:99999;parameter1=value2;parameter2=value3", new ByteArrayDeserializer(), new ByteArrayDeserializer());

...

No public interfaces would be added, however a new contructor would be added to KafkaConsumer, KafkaProducer and KafkaProducerKafkaAdminClient

public KafkaConsumer(String connectionString,

...

• As mentioned above, there would be an addition to KafkaConsumer, KafkaProducer and KafkaProducer.KafkaAdminClient
• An utility class will be added to map the string parameters to current configurations. That constructor would then delegate to the already existing code.

...