Jafka Versions Save

• upgrade jackson to fix CVE-2018-19360 and others
• upgrade version of netty and slf4j

• update some dependencies

  • slf4j-api 1.7.25
  • jackson 2.9.6
  • netty-all 4.1.29.Final
  • jopt-simple 5.0.4
  • junit 4.12

• update pom file for release

• upgrade zkclient to 2.1.2 (fixed NPE while deleting an not exists node of zookeeper)
• update some documents

• fixed register the consumer at short time on reboot
• reformat more code
• fixed united test on some faster cpu

• show version of shutdown log
• hold NoNodeException during rebalancing
• change zookeeper client to kazoo for python client
• reformat some code
• fixed blacklist on mirror consumer
• start the rebalance thread after watcher prepared

• fixed: register the consumer first before rebalancing

Now jafka has his domain jafka.io, and change the package to io.jafka.

• create all log files
• fixed IndexOutOfBoundsException without partition files
• fixed java.nio.channels.ClosedByInterruptException before rebalancing

• add a simple producer with string message base zookeeper
• add a simple consumer with string message base zookeeper
• upgrade java wrapper service to 3.5.30
• support macOS 10.12
• clean code

• improved the tips while rebalancing failed
• support timeout for producer client
• remove auto-reconnecting at the client without error
• enforce brokerId to be a non-negative integer
• auto commit the offset before closed the client
• update log4j/zkclient
• fixed the broker name on IPv6 machine
• fixed port checking for test
• fixed client exception without brokers
• fixed comress message's offset error for auto commit
• fixed some spelling mistakes
• clean some codes and add some comments
• improved the default log4j formatter