Doesn't seem to work for non-zero partitions #4
Description
When a publisher calls producer.send(), if trying to manually set the partition to a value other than 0, the send() call times out and it doesn't work.
E.g.:
// ProducerRecord(String topic, Integer partition, K key, V value)
producer.send(new ProducerRecord<String, DataRecord>(topic, 1, key, record), new Callback() {
This just hangs and eventually times out:
[2022-12-10 14:10:53,545] INFO [Producer clientId=producer-1] Cluster ID: xhbGrNbVTYyH-J3cxc_kqQ (org.apache.kafka.clients.Metadata)
org.apache.kafka.common.errors.TimeoutException: Topic test1 not present in metadata after 60000 ms.
I'm assuming that the Proxy should work with any value of partition..?