[KAFKA-6076] Using new producer api of transaction twice failed when server run on Windows OS

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 0.11.0.1
• Component/s: core
• Labels: windows

Environment

OS: Windows 10 64bit
Kafka: kafka_2.11-0.11.0.1(https://www.apache.org/dyn/closer.cgi?path=/kafka/0.11.0.1/kafka_2.11-0.11.0.1.tgz)
JDK: 1.8.0_144 64bit
Client: kafka-clients 0.11.0.1

• Assignee: Unassigned
• Reporter: Orwen Xiang
• Created: 18/Oct/17 03:40
• Updated: 26/Feb/18 16:45
• Resolved: 26/Feb/18 16:45

Description

Can't invoke twice (begin,commit transaction) on same Kafka Producer instance when it connected Kafka server run on windows 10.

But same code can run successfully when Kafka server run on CentOS 7.3 64bit with same Kafka server code base and config.

Producer code looks like:

Map<String, Object> props = new HashMap<>();
props.put("bootstrap.servers", "localhost:9092");
props.put("transactional.id", "my-transactional-id");
Producer<String, String> producer = new KafkaProducer<>(props, new StringSerializer(), new StringSerializer());
producer.initTransactions();
try

{ producer.beginTransaction(); for (int i = 0; i < 100; i++) producer.send(new ProducerRecord<>("test-2", Integer.toString(i), Integer.toString(i))); producer.commitTransaction(); System.out.println("sent one time done"); producer.beginTransaction(); for (int i = 0; i < 100; i++) producer.send(new ProducerRecord<>("test-2", Integer.toString(i), Integer.toString(i))); producer.commitTransaction(); System.out.println("sent two time done"); }

catch (ProducerFencedException | OutOfOrderSequenceException | AuthorizationException e)

{ producer.close(); }

catch (KafkaException e)

{ producer.abortTransaction(); }

producer.close();

Issue Links

• duplicates: KAFKA-6052 Windows: Consumers not polling when isolation.level=read_committed